Dispatcher#

Dispatching jobs to the server

covalent.dispatch(orig_lattice, dispatcher_addr=None)#

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 (Optional[str]) – The address of the dispatcher server. If None then then defaults to the address set in Covalent’s config.

Return type

Callable

Returns

Wrapper function which takes the inputs of the workflow as arguments

covalent.dispatch_sync(lattice, dispatcher_addr=None)#

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 (Optional[str]) – The address of the dispatcher server. If None then then defaults to the address set in Covalent’s config.

Return type

Callable

Returns

Wrapper function which takes the inputs of the workflow as arguments