Matthew Blau
03/17/2021, 3:20 PMMatthew Blau
03/17/2021, 3:21 PMstart = StartContainer()
l`ogs = GetContainerLogs(trigger=always_run)`
status_code = WaitOnContainer()
## set task dependencies via functional API
with Flow(name="ispottv",
state_handlers=[slack_notifier],
) as flow:
start_container = start(container_id=container)
code = status_code(container_id=container, upstream_tasks=[start_container])
collect_logs = logs(container_id=container, upstream_tasks=[code])
itay livni
03/17/2021, 3:54 PMsignals
?
https://docs.prefect.io/core/getting_started/next-steps.html#signals