meshed.tools

Tools to work with meshed

meshed.tools.launch_funcs_webservice(funcs: List[Callable])[source]

Launches a web service application with the specified functions.

Parameters:

funcs (List[Callable]) – functions to be hosted by the web service

meshed.tools.launch_webservice(funcs_to_cloudify, wait_after_start_seconds=10)[source]

Context manager to launch a web service application in a separate process.

meshed.tools.mk_dag_with_ws_funcs(dag: DAG, ws_funcs: dict) → DAG[source]

Creates a new DAG with the web service functions.

Parameters:

  • dag (DAG) – DAG to be hybridized

  • ws_funcs (dict) – mapping of web service functions

Returns:

new DAG with the web service functions

Return type:

DAG

meshed.tools.mk_hybrid_dag(dag: DAG, func_ids_to_cloudify: list)[source]

Creates a hybrid DAG that uses the web service for the specified functions.

Parameters:

  • dag (DAG) – dag to be hybridized

  • func_ids_to_cloudify (list) – list of function ids to be cloudified

Returns:

namedtuple with funcs_to_cloudify, ws_dag and ws_funcs

Return type:

namedtuple