PlexusJobOperator

Plexus

Submits a Plexus job.

View Source

Last Updated: Jan. 23, 2021

Access Instructions

Install the Plexus provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

job_paramsdictparameters required to launch a job.

Documentation

Submits a Plexus job.

Required job parameters are the following
  • “name”: job name created by user.

  • “app”: name of the application to run. found in Plexus UI.

  • “queue”: public cluster name. found in Plexus UI.

  • “num_nodes”: number of nodes.

  • “num_cores”: number of cores per node.

Example DAGs

Was this page helpful?