Method GetTaskRunByIdempotencyKey

internal/task/manager_test.go:1896–1906

(
	_ context.Context,
	key string,
	origin Origin,
)

}

func (s *inMemoryManagerStore) GetTaskRunByIdempotencyKey(
	_ context.Context,
	key string,
	origin Origin,
) (Run, error) {
	record, ok := s.idempotencyByKey[idempotencyKey(origin, key)]
	if !ok {
		return Run{}, ErrTaskRunIdempotencyNotFound
	}
	return s.GetTaskRun(context.Background(), record.RunID)
}

func (s *inMemoryManagerStore) SaveTaskRunIdempotency(
	_ context.Context,