workflow

Module Contents

class workflow.MonitorPE(output=None)

set_monitor(monitor, start_progress=0, end_progress=100)

class workflow.GenericWPS(url, identifier, resource="resource", inputs=list, output=None, headers=None)

progress(execution)

monitor_execution(execution)

_build_wps_inputs()

_build_wps_outputs()

execute()

_set_inputs(inputs)

process(inputs)

_process(inputs)

class workflow.EsgSearch(url, search_url="https://esgf-data.dkrz.de/esg-search", constraints="project:CORDEX", query=None, limit=100, search_type="File", distrib=False, replica=False, latest=True, temporal=False, start=None, end=None)

_process(inputs)

class workflow.SolrSearch(url, query, filter_query=None)

Run search against birdhouse solr index and return a list of download urls.

process(inputs)

class workflow.Download(url, headers=None)

_process(inputs)

class workflow.ThreddsDownload(url, catalog_url, headers=None)

_process(inputs)

workflow.esgf_workflow(source, worker, monitor=None, headers=None)

workflow.thredds_workflow(source, worker, monitor=None, headers=None)

workflow.solr_workflow(source, worker, monitor=None, headers=None)

workflow.run(workflow, monitor=None, headers=None)