pipes

dagster-io · Dec 8, 2023 · f24d391 · f24d391
1 parent 65c1226
commit f24d391
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/python_modules/dagster/dagster/_core/pipes/context.py b/python_modules/dagster/dagster/_core/pipes/context.py
@@ -39,7 +39,7 @@
 from dagster._core.errors import DagsterPipesExecutionError
 from dagster._core.events import EngineEventData
 from dagster._core.execution.context.compute import OpExecutionContext
-from dagster._core.execution.context.invocation import RunlessOpExecutionContext
+from dagster._core.execution.context.invocation import BaseRunlessContext
 from dagster._utils.error import (
     ExceptionInfo,
     SerializableErrorInfo,
@@ -388,8 +388,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, RunlessOpExecutionContext) else context.job_name,
-        retry_number=0 if isinstance(context, RunlessOpExecutionContext) else context.retry_number,
+        job_name=None if isinstance(context, BaseRunlessContext) else context.job_name,
+        retry_number=0 if isinstance(context, BaseRunlessContext) else context.retry_number,
         extras=extras or {},
     )