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