diff --git a/src/conductor/client/workflow/executor/workflow_executor.py b/src/conductor/client/workflow/executor/workflow_executor.py index 88d3c6437..5bb360fd3 100644 --- a/src/conductor/client/workflow/executor/workflow_executor.py +++ b/src/conductor/client/workflow/executor/workflow_executor.py @@ -195,7 +195,7 @@ def get_by_correlation_ids_and_names(self, batch_request: CorrelationIdsSearchRe also includes workflows that are completed otherwise only running workflows are returned """ return self.workflow_client.get_by_correlation_ids_in_batch(batch_request=batch_request, - include_closed=include_closed, + include_completed=include_closed, include_tasks=include_tasks) def pause(self, workflow_id: str) -> None: