Skip to content

Commit

Permalink
pipe parent class around
Browse files Browse the repository at this point in the history
  • Loading branch information
jamiedemaria committed Sep 22, 2023
1 parent c3adde0 commit 2c59e3b
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions python_modules/dagster/dagster/_core/ext/context.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
from dagster._core.definitions.partition_key_range import PartitionKeyRange
from dagster._core.definitions.time_window_partitions import TimeWindow
from dagster._core.execution.context.compute import OpExecutionContext
from dagster._core.execution.context.invocation import BoundOpExecutionContext
from dagster._core.execution.context.invocation import BoundExecutionContext


class ExtMessageHandler:
Expand Down Expand Up @@ -155,8 +155,8 @@ def build_external_execution_context_data(
_convert_time_window(partition_time_window) if partition_time_window else None
),
run_id=context.run_id,
job_name=None if isinstance(context, BoundOpExecutionContext) else context.job_name,
retry_number=0 if isinstance(context, BoundOpExecutionContext) else context.retry_number,
job_name=None if isinstance(context, BoundExecutionContext) else context.job_name,
retry_number=0 if isinstance(context, BoundExecutionContext) else context.retry_number,
extras=extras or {},
)

Expand Down

0 comments on commit 2c59e3b

Please sign in to comment.