Skip to main content

Python wrapper for the Xenon API.

Project description

ZenodoBadge Documentation Status Apache2License BuildStatus CodacyBadge

Python interface to the Xenon middleware library, v. 2.0. Xenon provides a simple programming interface to various pieces of software that can be used to access distributed compute and storage resources.

Underneath it uses GRPC, to connect to the Xenon-GRPC service. We’ve taken care to mirror the original Java API in this Python module as much as possible.

Installing

Clone this repository, and do:

pip install .

The code will appear on PyPI when it is ready for release.

Documentation

The compiled documentation is hosted on Read the Docs. This includes a quick-start guide.

Development

PyXenon ships with the Xenon-GRPC jar-file and command-line executable. If these need upgrading, build them manually, following instructions at Xenon-GRPC, and place the contents of the build/install/xenon-grpc-shadow folder (lib and bin) here.

To generate the GRPC code, run scripts/protoc.sh from the project root.

Testing

Unit tests all run against the local scheduler and the file adaptor for filesystems. To run them, just do:

$ pytest ./tests

For faster testing it may be useful to start the xenon-grpc daemon manually; start it in a separate terminal as it may give useful output for debugging.

For integration testing, run the following docker container to test against remote slurm

docker run --detach --publish 10022:22 nlesc/xenon-slurm:17

An example of some code running against this container is in examples/tutorial.py.

Example

import xenon
import os

xenon.init()

# create a new job scheduler, using SSH to localhost to submit new jobs.
with xenon.Scheduler.create(
        adaptor='ssh', location='localhost') as scheduler:

    # make a new job description. The executable must already be present on
    # the target host.
    target = xenon.Path('.') / 'stdout.txt'
    desc = xenon.JobDescription(
        executable='hostname',
        stdout=str(target))

    # submit a job
    job = scheduler.submit_batch_job(desc)
    status = scheduler.wait_until_done(job, 1000)

    # read the standard output of the job. We can do this directly because
    # we ran on localhost, otherwise, we need to transfer the file first.
    with open(target) as f:
        print(f.read())

Contributing

Contributions can be made using GitHub pull requests. To add a feature, first install the test requirements

pip install -U tox

and then run

tox

until all tests succeed. The command checks against flake8 code standards and syntax errors on Python 3.5 and 3.6. Then commit, to make sure the change didn’t break any code. The pull request will be evaluated in Travis.

Project details


Download files

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

Source Distribution

pyxenon-2.2.2.tar.gz (20.2 MB view details)

Uploaded Source

File details

Details for the file pyxenon-2.2.2.tar.gz.

File metadata

  • Download URL: pyxenon-2.2.2.tar.gz
  • Upload date:
  • Size: 20.2 MB
  • Tags: Source
  • Uploaded using Trusted Publishing? No

File hashes

Hashes for pyxenon-2.2.2.tar.gz
Algorithm Hash digest
SHA256 16e82a7579b9adef12dab0591b2a25d6678842b5d89d79a0980592207da0f14c
MD5 864980ac9243212b39ba092c108c5525
BLAKE2b-256 0aca8452cb702509981c7d8fbb9f66a02d2296941c4d049eb5524e9b90cfc347

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page