PlexusJobOperator
PlexusSubmits a Plexus job.
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_paramsparameters 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.