diff --git a/dbos/_conductor/conductor.py b/dbos/_conductor/conductor.py index caaa666f6..9d5831b2b 100644 --- a/dbos/_conductor/conductor.py +++ b/dbos/_conductor/conductor.py @@ -340,7 +340,7 @@ def run(self) -> None: list_steps_message = p.ListStepsRequest.from_json(message) step_info = None try: - self.dbos._sys_db.list_workflow_steps( + step_info = self.dbos._sys_db.list_workflow_steps( list_steps_message.workflow_id ) except Exception as e: