idq.condor

describe module, architecture, etc.

class idq.condor.JobType(value)

An enumeration.

idq.condor.create_batch_dag(gps_start, gps_end, jobdir, batches, verbose=False, quiet=False, retry=0, accounting_group='not.real', accounting_group_user='mambauser', universe='vanilla', **kwargs)

generates a DAG for batch jobs

idq.condor.create_stream_dag(config, config_path, jobdir, initial_lookback=0, skip_timeseries=False, skip_report=False, verbose=False, quiet=False, retry=0, accounting_group='not.real', accounting_group_user='mambauser', universe='vanilla', **kwargs)

generates a DAG for streaming jobs

idq.condor.submit_dag(dag_path, block=True)

submit the condor_dag and monitor it return with the dag’s returncode