Dispatcher#

Dispatching jobs to the server

covalent.dispatch(orig_lattice, dispatcher_addr='localhost:48008')#

Wrapping the dispatching functionality to allow input passing and server address specification.

Afterwards, send the lattice to the dispatcher server and return the assigned dispatch id.

Parameters
  • orig_lattice (Lattice) – The lattice/workflow to send to the dispatcher server.

  • dispatcher_addr (str) – The address of the dispatcher server.

Return type

Callable

Returns

Wrapper function which takes the inputs of the workflow as arguments

covalent.dispatch_sync(lattice, dispatcher_addr='localhost:48008')#

Wrapping the synchronous dispatching functionality to allow input passing and server address specification.

Afterwards, sends the lattice to the dispatcher server and return the result of the executed workflow.

Parameters
  • orig_lattice – The lattice/workflow to send to the dispatcher server.

  • dispatcher_addr (str) – The address of the dispatcher server.

Return type

Callable

Returns

Wrapper function which takes the inputs of the workflow as arguments