Skip to main content
Pre-release

This release is a pre-release and may not be stable for production use.

ewoksjob

Pipeline Code style: black License Coverage Docs PyPI

Utilities for job scheduling of ewoks workflows.

Ewoksjob provides an ewoks interface for asynchronous and distributed scheduling of ewoks from python.

Note that ewoksjob distributes the execution of workflows while ewoksdask distributes the execution of tasks in a workflow. So in the context of workflows, job scheduling exists on two levels.

The primary clients that need to schedule workflows are

Installation

Install on the client side

pip install ewoksjob

Install on the worker side

pip install ewoksjob[worker]

Getting started

Start a worker pool that can execute ewoks graphs

ewoksjob worker

Submit a workflow on the client side

from ewoksjob.client import submit

workflow = {"graph": {"id": "mygraph"}}
future = submit(args=(workflow,))
result = future.result(timeout=None)

Note that both environments need to be able to import celeryconfig which contains celery configuration (mainly the message broker and result backend URL's).

Hello world example

Clone the git repository and start a worker pool

scripts/worker.sh --sql

Submit workflows

scripts/runjobs.sh --sql

Tests

pytest --pyargs ewoksjob

To run the redis tests you need redis-server (e.g. conda install redis-server).

Documentation

https://ewoksjob.readthedocs.io/

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

ewoksjob-1.6.0rc2.tar.gz (42.2 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

ewoksjob-1.6.0rc2-py3-none-any.whl (58.8 kB view details)

Uploaded Python 3

File details

Details for the file ewoksjob-1.6.0rc2.tar.gz.

File metadata

  • Download URL: ewoksjob-1.6.0rc2.tar.gz
  • Upload date:
  • Size: 42.2 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/7.0.0 CPython/3.13.14

File hashes

Hashes for ewoksjob-1.6.0rc2.tar.gz
Algorithm Hash digest
SHA256 5909e77517a8ea6342acd4518b4604940071d2605b33da268d280449ac666510
MD5 630cc57be960cebb9b610be9c50f68c9
BLAKE2b-256 8ce33d4451e34580c08d6289baea1ee9736d5bcef82145737adb803d71488369

See more details on using hashes here.

Provenance

The following attestation bundles were made for ewoksjob-1.6.0rc2.tar.gz:

Publisher: release.yml on ewoks-kit/ewoksjob

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file ewoksjob-1.6.0rc2-py3-none-any.whl.

File metadata

  • Download URL: ewoksjob-1.6.0rc2-py3-none-any.whl
  • Upload date:
  • Size: 58.8 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/7.0.0 CPython/3.13.14

File hashes

Hashes for ewoksjob-1.6.0rc2-py3-none-any.whl
Algorithm Hash digest
SHA256 eda61f024ae59ae3cbaf65f62e8e4762478174556c1eb3657b4decffa48733e1
MD5 b636649e3a783f9dcc1bb7777f16126c
BLAKE2b-256 b2fe2107ac2b215da8af26755dc3f5775db8e1d50dbae6e733304c0e1c77ee2a

See more details on using hashes here.

Provenance

The following attestation bundles were made for ewoksjob-1.6.0rc2-py3-none-any.whl:

Publisher: release.yml on ewoks-kit/ewoksjob

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Release history Release notifications | RSS feed

This release

1.6.0rc2 This release

2 files

1.5.0

2 files

1.4.1

2 files

1.4.0

2 files

1.3.4

1 file

1.3.3

1 file

1.3.2

1 file

1.3.1

1 file

1.3.0

1 file

1.2.0

1 file

1.1.2

1 file

1.1.1

1 file

1.1.0

1 file

1.0.0

1 file

0.7.0

1 file

0.6.1

1 file

0.6.0

1 file

0.5.0

1 file

0.4.0

1 file

0.3.3

1 file

0.3.2

1 file

0.3.1

1 file

0.3.0

1 file

0.2.5

1 file

0.2.4

1 file

0.2.3

1 file

0.2.2

1 file

0.2.1

1 file

0.2.0

1 file

0.1.1

1 file

0.1.0

1 file

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page