Querying Task (Electron) Status in a Notebook#
Check the status of individual tasks in a workflow using the Covalent Result object.
Prerequisites#
Define and run a workflow:
[1]:
import covalent as ct
import time
@ct.electron
def add(x, y):
time.sleep(5)
return x + y
@ct.electron
def multiply(x, y):
return x * y
@ct.lattice
def workflow(x, y):
res_1 = add(x=x, y=y)
return multiply(x=res_1, y=y)
View the transport graph in the Covalent GUI as described in the User Interface Reference to determine the node IDs for the electrons.
Query the individual electrons’ execution status using the node IDs from the transport graph.
[2]:
dispatch_id = ct.dispatch(workflow)(x=1, y=2)
time.sleep(2)
result = ct.get_result(dispatch_id=dispatch_id, wait=False)
result.get_node_result(node_id=0)['status']
[2]:
Status(STATUS='NEW_OBJECT')
Note the query for the execution status via the status field. Possible values are PENDING, FAILED, RUNNING, or COMPLETED. A node can also have status NEW_OBJECT if the task has not yet been been put in a queue for execution.