import time
from metaflow.plugins.deployer import Deployer
ar = Deployer(flow_file="../../try.py").argo_workflows(name="madhur")
ar_obj = ar.create()
print(ar_obj.production_token)
result = ar_obj.trigger(myparam=300)
print(result.status)
run = result.run
while run is None:
print("trying again...")
run = result.run
print(result.run)
print(result.status)
time.sleep(120)
print(result.terminate())
Usage as follows: