Blake
08/09/2024, 7:19 PMexpected_start_time
to scheduled_start_time
?
def get_scheduled_start_time() -> pendulum.DateTime:
flow_run_ctx = FlowRunContext.get()
run_id = get_id()
if flow_run_ctx is None and run_id is None:
return pendulum.now("utc")
elif flow_run_ctx is None:
flow_run = from_sync.call_soon_in_loop_thread(
create_call(_get_flow_run, run_id)
).result()
return flow_run.expected_start_time
else:
return flow_run_ctx.flow_run.expected_start_time
Marvin
08/09/2024, 7:19 PMexpected_start_time
to scheduled_start_time
in the runtime context isn't directly stated in the provided documentation snippets. However, it appears that Prefect aims to standardize terminology across different contexts for clarity. You can refer to the detailed information on runtime context in Prefect docs.
For further clarity and possible discussions on implementation details, you may consider looking into Prefect's GitHub issues or forums. If you need additional assistance, let me know how to help further.