pocket_coffea.executors package

Contents

pocket_coffea.executors package#

Submodules#

pocket_coffea.executors.executors_DESY_NAF module#

pocket_coffea.executors.executors_RWTH module#

pocket_coffea.executors.executors_T3_CH_PSI module#

class pocket_coffea.executors.executors_T3_CH_PSI.DaskExecutorFactory(run_options, outputdir, **kwargs)#

Bases: ExecutorFactoryABC

At T3_CH_PSI the dask executor is based on slurm

close()#
customized_args()#
get()#
get_worker_env()#
setup()#

Start the DASK cluster here

pocket_coffea.executors.executors_T3_CH_PSI.get_executor_factory(executor_name, **kwargs)#

pocket_coffea.executors.executors_base module#

class pocket_coffea.executors.executors_base.ExecutorFactoryABC(run_options, **kwargs)#

Bases: ABC

close()#
customized_args()#
abstract get()#
set_env()#
setup()#
setup_proxyfile()#
class pocket_coffea.executors.executors_base.FuturesExecutorFactory(run_options, **kwargs)#

Bases: ExecutorFactoryABC

customized_args()#
get()#
class pocket_coffea.executors.executors_base.IterativeExecutorFactory(run_options, **kwargs)#

Bases: ExecutorFactoryABC

get()#
pocket_coffea.executors.executors_base.get_executor_factory(executor_name, **kwargs)#

pocket_coffea.executors.executors_casa module#

class pocket_coffea.executors.executors_casa.DaskExecutorFactory(run_options, outputdir, **kwargs)#

Bases: ExecutorFactoryABC

close()#
customized_args()#
get()#
setup()#

Start the DASK cluster here

pocket_coffea.executors.executors_casa.get_executor_factory(executor_name, **kwargs)#

pocket_coffea.executors.executors_cern_swan module#

pocket_coffea.executors.executors_infn_af module#

pocket_coffea.executors.executors_lxplus module#

class pocket_coffea.executors.executors_lxplus.DaskExecutorFactory(run_options, outputdir, **kwargs)#

Bases: ExecutorFactoryABC

close()#
customized_args()#
get()#
get_worker_env()#
setup()#

Start the DASK cluster here

class pocket_coffea.executors.executors_lxplus.ExecutorFactoryCondorCERN(run_options, **kwargs)#

Bases: ExecutorFactoryManualABC

get()#
prepare_jobs(splits)#
recreate_jobs(jobs_to_recreate)#
submit_jobs(jobs_config)#

Prepare job config and script and submit the jobs to the cluster

pocket_coffea.executors.executors_lxplus.get_executor_factory(executor_name, **kwargs)#

pocket_coffea.executors.executors_purdue_af module#

class pocket_coffea.executors.executors_purdue_af.DaskGatewayExecutorFactory(run_options, outputdir, **kwargs)#

Bases: ExecutorFactoryABC

close()#
customized_args()#
get()#
get_worker_env()#
setup()#

Start the DASK cluster here

setup_proxyfile()#
pocket_coffea.executors.executors_purdue_af.get_executor_factory(executor_name, **kwargs)#

Module contents#

Contents