Skip to main content
Ctrl+K
ewoksjob 0.6

Site Navigation

  • Getting started
  • Named queues
  • Slurm
  • Usage with BLISS at the ESRF
  • API documentation
  • gitlab
  • pypi

Site Navigation

  • Getting started
  • Named queues
  • Slurm
  • Usage with BLISS at the ESRF
  • API documentation
  • gitlab
  • pypi

Section Navigation

  • ewoksjob
    • ewoksjob.apps
      • ewoksjob.apps.errors
        • ewoksjob.apps.errors.replace_exception_for_client
        • ewoksjob.apps.errors.EwoksJobBaseException
        • ewoksjob.apps.errors.EwoksJobBaseExceptionCause
        • ewoksjob.apps.errors.EwoksJobException
        • ewoksjob.apps.errors.EwoksJobExceptionCause
      • ewoksjob.apps.ewoks
    • ewoksjob.client
      • ewoksjob.client.celery
        • ewoksjob.client.celery.tasks
        • ewoksjob.client.celery.utils
      • ewoksjob.client.dummy_workflow
        • ewoksjob.client.dummy_workflow.dummy_workflow
        • ewoksjob.client.dummy_workflow.result
      • ewoksjob.client.local
        • ewoksjob.client.local.pool
        • ewoksjob.client.local.tasks
        • ewoksjob.client.local.utils
    • ewoksjob.config
      • ewoksjob.config.get_cfg_type
      • ewoksjob.config.get_cfg_uri
      • ewoksjob.config.read_configuration
      • ewoksjob.config.EwoksLoader
    • ewoksjob.events
      • ewoksjob.events.handlers
        • ewoksjob.events.handlers.redis
      • ewoksjob.events.readers
        • ewoksjob.events.readers.instantiate_reader
        • ewoksjob.events.readers.base
        • ewoksjob.events.readers.redis
        • ewoksjob.events.readers.sqlite3
    • ewoksjob.tests
      • ewoksjob.tests.test_convert
        • ewoksjob.tests.test_convert.assert_convert
        • ewoksjob.tests.test_convert.test_convert
        • ewoksjob.tests.test_convert.test_convert_local
      • ewoksjob.tests.test_convert_and_execute
        • ewoksjob.tests.test_convert_and_execute.assert_submit
        • ewoksjob.tests.test_convert_and_execute.assert_submit_test
        • ewoksjob.tests.test_convert_and_execute.test_submit
        • ewoksjob.tests.test_convert_and_execute.test_submit_local
      • ewoksjob.tests.test_execute
        • ewoksjob.tests.test_execute.assert_submit
        • ewoksjob.tests.test_execute.assert_submit_test
        • ewoksjob.tests.test_execute.test_submit
        • ewoksjob.tests.test_execute.test_submit_local
      • ewoksjob.tests.test_task_discovery
        • ewoksjob.tests.test_task_discovery.assert_submit
        • ewoksjob.tests.test_task_discovery.test_submit
        • ewoksjob.tests.test_task_discovery.test_submit_local
      • ewoksjob.tests.utils
        • ewoksjob.tests.utils.get_result
        • ewoksjob.tests.utils.has_redis
        • ewoksjob.tests.utils.wait_not_finished
    • ewoksjob.worker
      • ewoksjob.worker.executor
        • ewoksjob.worker.executor.get_execute_method
        • ewoksjob.worker.executor.set_execute_getter
      • ewoksjob.worker.options
        • ewoksjob.worker.options.add_options
        • ewoksjob.worker.options.apply_worker_options
        • ewoksjob.worker.options.CustomWorkersBootStep
      • ewoksjob.worker.process
        • ewoksjob.worker.process.accept_callback_main
        • ewoksjob.worker.process.parse_exception
        • ewoksjob.worker.process.process_initializer
        • ewoksjob.worker.process.subprocess_main
        • ewoksjob.worker.process.ApplyResult
        • ewoksjob.worker.process.TaskPool
      • ewoksjob.worker.process_utils
        • ewoksjob.worker.process_utils.process_initializer
      • ewoksjob.worker.slurm
        • ewoksjob.worker.slurm.TaskPool
  • API documentation
  • ewoksjob.client.celery
  • ewoksjob.cli...

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]

previous

ewoksjob.client.celery.tasks.execute_test_graph

next

ewoksjob.client.celery.utils.cancel
Show Source

© Copyright 2019-2024, ESRF.

ewoksjob 0.6.0