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
09/02/2022, 4:39 PMsubmit
but it depends on the data that you’re passingKeith Hickey
09/06/2022, 5:00 PMFlorian Giroud
10/05/2022, 8:10 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
11/22/2022, 9:00 PMAnna Geller
11/22/2022, 11:05 PMTodd de Quincey
11/23/2022, 5:07 AMAnna Geller
11/23/2022, 1:31 PMBrandon 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
11/28/2022, 5:45 PMwait_for
to indicate an implicit relationship.Oscar Björhn
11/28/2022, 6:08 PMZanie
11/28/2022, 6:14 PMwait_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
01/19/2023, 8:38 PMFlorian Giroud
01/19/2023, 8:41 PM