cannot use workflowNotificationsStreamFunc (variable of type func(ctx context.Context, executionID string) (chan testkube.TestWorkflowExecutionNotification, error)) as func(ctx context.Context, executionID string) (<-chan testkube.TestWorkflowExecutionNotification, error) value in argument to agent.NewAgent

cannot use workflowNotificationsStreamFunc (variable of type func(ctx context.Context, executionID string) (chan testkube.TestWorkflowExecutionNotification, error)) as func(ctx context.Context, executionID string) (<-chan testkube.TestWorkflowExecutionNotification, error) value in argument to agent.NewAgent

cannot use workflowNotificationsStreamFunc (variable of type func(ctx context.Context, executionID string) (chan testkube.TestWorkflowExecutionNotification, error)) as func(ctx context.Context, executionID string) (<-chan testkube.TestWorkflowExecutionNotification, error) value in argument to agent.NewAgent (typecheck)

cannot use mockTestWorkflowExecutor (variable of type *testworkflowexecutor.MockTestWorkflowExecutor) as executionworker.Worker value in argument to NewService: *testworkflowexecutor.MockTestWorkflowExecutor does not implement executionworker.Worker (missing method Destroy)

cannot use mockTestWorkflowRepository (variable of type *testworkflow.MockRepository) as testworkflowexecutor.TestWorkflowExecutor value in argument to NewService: *testworkflow.MockRepository does not implement testworkflowexecutor.TestWorkflowExecutor (missing method Control)

cannot use WithClusterID(testClusterID) (value of type Option) as testworkflow.Repository value in argument to NewService: Option does not implement testworkflow.Repository (missing method DeleteAll) (typecheck)