malleefowl.workflow¶
Module Contents¶
-
malleefowl.workflow.LOGGER¶
-
class
malleefowl.workflow.MonitorPE(output=None)¶ Bases:
dispel4py.base.BasePE-
INPUT_NAME= input¶
-
OUTPUT_NAME= output¶
-
set_monitor(self, monitor, start_progress=0, end_progress=100)¶
-
-
class
malleefowl.workflow.GenericWPS(url, identifier, resource='resource', inputs=[], output=None, headers=None)¶ Bases:
malleefowl.workflow.MonitorPE-
STATUS_NAME= status¶
-
STATUS_LOCATION_NAME= status_location¶
-
progress(self, execution)¶
-
monitor_execution(self, execution)¶
-
_build_wps_inputs(self)¶
-
_build_wps_outputs(self)¶
-
execute(self)¶
-
_set_inputs(self, inputs)¶
-
process(self, inputs)¶
-
_process(self, inputs)¶
-
-
class
malleefowl.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)¶ Bases:
malleefowl.workflow.GenericWPS-
_process(self, inputs)¶
-
-
class
malleefowl.workflow.SolrSearch(url, query, filter_query=None)¶ Bases:
malleefowl.workflow.MonitorPERun search against birdhouse solr index and return a list of download urls.
-
process(self, inputs)¶
-
-
class
malleefowl.workflow.Download(url, headers=None)¶ Bases:
malleefowl.workflow.GenericWPS-
_process(self, inputs)¶
-
-
class
malleefowl.workflow.ThreddsDownload(url, catalog_url, headers=None)¶ Bases:
malleefowl.workflow.GenericWPS-
_process(self, inputs)¶
-
-
malleefowl.workflow.esgf_workflow(source, worker, monitor=None, headers=None)¶
-
malleefowl.workflow.thredds_workflow(source, worker, monitor=None, headers=None)¶
-
malleefowl.workflow.solr_workflow(source, worker, monitor=None, headers=None)¶
-
malleefowl.workflow.run(workflow, monitor=None, headers=None)¶