Rohit Motiani
12/28/2022, 5:20 PMKalise Richmond
12/28/2022, 5:44 PMfrom prefect import task, flow
from prefect_dask.task_runners import DaskTaskRunner
@task
def run_product():
print('hello')
@task
def run_field():
print('hello')
@flow(task_runner=DaskTaskRunner())
def main_flow():
result = run_product.submit()
result = run_field.submit()
if __name__ == "__main__":
main_flow()
Rohit Motiani
12/28/2022, 7:26 PMAnna Geller
01/04/2023, 10:31 AMprefect version
and prefect config view
? did you start Orion? you can do that using prefect orion start
if this doesn't help, could be an issue with the network i.e. Dask runner can't reach orionEmil Christensen
01/04/2023, 4:55 PMprefect version
returns in your IDE and in your terminal where you’re spinning up Orion?Rohit Motiani
01/05/2023, 3:57 PMKalise Richmond
01/05/2023, 10:43 PMRohit Motiani
01/06/2023, 11:24 PMKalise Richmond
01/06/2023, 11:31 PMRohit Motiani
01/07/2023, 5:05 AMEmil Christensen
01/09/2023, 3:00 PMprefect version
text and the error text here?Rohit Motiani
01/10/2023, 5:38 PMEmil Christensen
01/20/2023, 9:47 PM