yu zeng
06/23/2022, 3:44 AMKevin Kho
yu zeng
06/23/2022, 4:16 AMKevin Kho
yu zeng
06/23/2022, 4:33 AMKevin Kho
yu zeng
06/23/2022, 5:11 AMKevin Kho
with dask.annotate(priority=10):
future = client.submit(func, *args)
so you might be able to do it in a Prefect task like this:
from dask.distributed import worker_client
@task
def mytask():
with worker_client() as client:
with dask.annotate(priority=10):
future = client.submit(func, *args)
return future.result()
not sure this would workyu zeng
06/23/2022, 5:39 AMfrom dask.distributed import worker_client
@task
def pre_task():
return [1,2,3]
@task
def mytask( some_thing ):
with worker_client() as client:
with dask.annotate(priority=10):
future = client.submit(func, some_thing )
return future.result()
mytask.map( pre_task() )
hi kevin thanks again. like you says, i think i can implement mapping priority in this way ?Kevin Kho
client.submit()
to submit a task already, so you are submitting another one so it’s not ideal but it might help your use case