Skip to content

Commit 8e919ca

Browse files
committed
Format dagster-async-executor after lockfile update
1 parent dd9f220 commit 8e919ca

2 files changed

Lines changed: 6 additions & 2 deletions

File tree

libraries/dagster-async-executor/dagster_async_executor/execution/plan/execute_plan.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -214,7 +214,9 @@ async def _trigger_hook(
214214
try:
215215
with user_code_error_boundary(
216216
HookExecutionError,
217-
lambda: f"Error occurred during the execution of hook_fn triggered for {op_label}",
217+
lambda: (
218+
f"Error occurred during the execution of hook_fn triggered for {op_label}"
219+
),
218220
log_manager=hook_context.log,
219221
):
220222
if inspect.iscoroutinefunction(hook_def.hook_fn):

libraries/dagster-async-executor/dagster_async_executor/execution/plan/execute_step.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -780,7 +780,9 @@ def _gen_fn():
780780
for elt in iterate_with_context(
781781
lambda: op_execution_error_boundary(
782782
DagsterExecutionHandleOutputError,
783-
msg_fn=lambda: f'Error occurred while handling output "{output_context.name}" of step "{step_context.step.key}":',
783+
msg_fn=lambda: (
784+
f'Error occurred while handling output "{output_context.name}" of step "{step_context.step.key}":'
785+
),
784786
step_context=step_context,
785787
step_key=step_context.step.key,
786788
output_name=output_context.name,

0 commit comments

Comments
 (0)