core.process.condor

core.process.condor.get_htcondor_client(maximum_jobs=100, **kwargs)[source]: Get a client for HTCondor cluster

core.process.condor.get_htcondor_logdir(logdir: Path | str | None) → Path[source]: A default log directory for condor

core.process.condor.get_htcondor_params(cores=1, memory='1GB', disk='1GB', death_timeout='600', logdir: Path | str | None = None) → Dict[source]: Parameters passed to HTCondorCluster

core.process.condor.get_htcondor_runner(maximum_jobs: int = 100, **kwargs)[source]: Initialize a prefect DaskTaskRunner based on HTCondorCluster