"""SWF workflows.""" import importlib __all__ = ('elasticsearch_export', ) def get_flow(flow_name): """Get flow by flow name. Args: flow_name (str): Name of the workflow. Returns: Flow: Flow object for the particular flow name. """ flow = importlib.import_module('.{}.flow'.format(flow_name), __name__) return flow.Flow()