YSF
09/02/2022, 2:25 AMOscar Björhn
09/02/2022, 7:20 AMJoao Moniz
09/02/2022, 8:52 AMOscar Björhn
09/02/2022, 9:28 AMTaylor Curran
09/02/2022, 1:34 PM.submit()
syntax in your flow code.
https://docs.prefect.io/tutorials/execution/?h=.submit#resultYSF
09/02/2022, 3:14 PMZanie
submit
but it depends on the data that you’re passingKeith Hickey
09/06/2022, 5:00 PMFlorian Giroud
10/05/2022, 8:10 PMFlorian Giroud
10/05/2022, 8:31 PM@flow(task_runner=SequentialTaskRunner())
def rfdm():
logger = get_run_logger()
<http://logger.info|logger.info>(f"I am an INFO message")
t1 = ingest_data.submit()
t2 = dbt_run.submit(wait_for=[t1])
t3 = a.submit(wait_for=[t2])
t4 = b.submit(wait_for=[t3])
Todd de Quincey
11/22/2022, 8:57 PMZanie
Anna Geller
Todd de Quincey
11/23/2022, 5:07 AMAnna Geller
Brandon Reid
11/28/2022, 4:11 PMYSF
11/28/2022, 4:23 PMBrandon Reid
11/28/2022, 4:26 PMOscar Björhn
11/28/2022, 5:10 PMZanie
Zanie
Zanie
wait_for
to indicate an implicit relationship.Oscar Björhn
11/28/2022, 6:08 PMZanie
wait_for
doesn’t have the same meaning outside of submit
since things are already running sequentially, we can definitely investigate a way to indicate implicit relationships in sequential code though!Oscar Björhn
11/28/2022, 6:15 PMTodd de Quincey
01/19/2023, 8:38 PMZanie
Florian Giroud
01/19/2023, 8:41 PM