james.lamb
06/23/2020, 3:24 PMIf you useas the execution environment for a flow, anyKubernetesJobEnvironment
you pass will be ignored and only the default executor will be usedexecutor
setup()
and execute()
methods for KubernetesJobEnvironment
are inherited from Environment
, and seem to be empty:
https://github.com/PrefectHQ/prefect/blob/master/src/prefect/environments/execution/base.py#L60-L75
and the run_flow()
method with KubernetesJobEnvironment
is inherited from Environment
, which says "run the flow with the default executor"
https://github.com/PrefectHQ/prefect/blob/fbe0d958d98db5c10013cbcf29cebeca77ba6bc7/src/prefect/environments/execution/base.py#L89Docker
• environment: KubernetesJobEnvironment
• executor: DaskExecutor
• agent: KubernetesAgent
• registered with / run from Prefect CloudJim Crist-Harif
06/23/2020, 3:39 PMjames.lamb
06/23/2020, 3:40 PMmaster
as of this morning. Those links above are to the most recent commit on master
.Jim Crist-Harif
06/23/2020, 3:41 PMjames.lamb
06/23/2020, 3:42 PMKubernetesJobEnvironment
and `DaskExecutor`", then I probably made a mistake along the way here.Jim Crist-Harif
06/23/2020, 3:44 PMjames.lamb
06/23/2020, 3:45 PMmaster
that Environment.run_flow()
(which KubernetesJobEnvironment
inherits) is now looking at the executor
you pass: https://github.com/PrefectHQ/prefect/blob/2746ba22ba73540e926e2ca6080591081c412ce6/src/prefect/environments/execution/base.py#L133-L141Jim Crist-Harif
06/23/2020, 3:47 PMjames.lamb
06/24/2020, 6:16 AM