Function TestEdgeCases

modules/backendscheduler/work/work_sharded_test.go:554–597

(t *testing.T)

}

func TestEdgeCases(t *testing.T) {
	work := New(Config{})

	t.Run("operations on nonexistent jobs", func(t *testing.T) {
		// These should not panic
		work.StartJob("nonexistent")
		work.CompleteJob("nonexistent")
		work.FailJob("nonexistent")
		work.SetJobCompactionOutput("nonexistent", []string{"output"})
		work.RemoveJob("nonexistent")

		job := work.GetJob("nonexistent")
		require.Nil(t, job)
	})

	t.Run("empty work operations", func(t *testing.T) {
		emptyWork := New(Config{})

		require.Equal(t, 0, len(emptyWork.ListJobs()))
		require.Empty(t, emptyWork.ListJobs())

		ctx := context.Background()
		foundJob := emptyWork.GetJobForWorker(ctx, "any-worker")
		require.Nil(t, foundJob)

		// Prune should not panic on empty work
		emptyWork.Prune(ctx)

		// Marshal/unmarshal empty work
		data, err := emptyWork.Marshal()
		require.NoError(t, err)

		newWork := New(Config{})
		err = newWork.Unmarshal(data)
		require.NoError(t, err)
		require.Equal(t, 0, len(newWork.ListJobs()))
	})

	t.Run("unmarshal invalid data", func(t *testing.T) {
		newWork := New(Config{})
		err := newWork.Unmarshal([]byte("invalid json"))
		require.Error(t, err)
	})
}

// TestFullMarshalUnmarshal tests the full work cache serialization across all shards
func TestFullMarshalUnmarshal(t *testing.T) {