deepr.jobs.YarnLauncher

class deepr.jobs.YarnLauncher(job, config, run_on_yarn=True, use_mlflow=False)[source]

Packages current environment, upload .pex and run yarn job.

__init__(job, config, run_on_yarn=True, use_mlflow=False)

Methods

__init__(job, config[, run_on_yarn, use_mlflow])

run()

Run Job

Attributes

run_on_yarn

use_mlflow

job

config