diff --git a/src/conductor/execution/executor.py b/src/conductor/execution/executor.py index d8c62d7..c2ea496 100644 --- a/src/conductor/execution/executor.py +++ b/src/conductor/execution/executor.py @@ -327,7 +327,9 @@ def _report_execution_results(self, plan: ExecutionPlan, elapsed_time: float): # Print the final execution result (succeeded or failed). if all_succeeded and (main_task_executed or main_task_cached): print() - print_bold("✨ Done! {}".format(self._get_elapsed_time_string(elapsed_time))) + print_bold( + "✨ Done! {}".format(self._get_elapsed_time_string(elapsed_time)) + ) else: # At least one task must have failed. @@ -341,7 +343,9 @@ def _report_execution_results(self, plan: ExecutionPlan, elapsed_time: float): assert len(failed_tasks) > 0 print() print_red( - "🔴 Task failed. {}".format(self._get_elapsed_time_string(elapsed_time)), + "🔴 Task failed. {}".format( + self._get_elapsed_time_string(elapsed_time) + ), bold=True, ) print() diff --git a/src/conductor/execution/version_index.py b/src/conductor/execution/version_index.py index 2428f29..7601f87 100644 --- a/src/conductor/execution/version_index.py +++ b/src/conductor/execution/version_index.py @@ -82,9 +82,9 @@ def create_or_load(cls, path: pathlib.Path) -> "VersionIndex": result = conn.execute(q.get_max_timestamp).fetchone() return VersionIndex( conn=conn, - last_timestamp=result[0] - if result is not None and result[0] is not None - else 0, + last_timestamp=( + result[0] if result is not None and result[0] is not None else 0 + ), ) # Need to create the DB