ewoksjob.client.celery.utils

Functions

cancel(task_id)

get_future(task_id)

rtype:

AsyncResult

get_not_finished_futures()

rtype:

List[AsyncResult]

get_not_finished_task_ids()

get_result(task_id, **kwargs)

get_workers()

rtype:

List[str]