Using eval to execute

kubeflow · Aug 16, 2019 · b3221be · b3221be
1 parent c453e21
commit b3221be
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/py/kubeflow/testing/run_e2e_workflow.py b/py/kubeflow/testing/run_e2e_workflow.py
@@ -297,10 +297,10 @@ def run(args, file_handler): # pylint: disable=too-many-statements,too-many-bran
       ui_urls[workflow_name] = ui_url
       logging.info("URL for workflow: %s", ui_url)
     else:
-      wf_result = util.run("python", w.py_func)
-      group, version = wf_result['apiVersion'].split('/')
+      wf_result = eval(w.py_func)
+      group, version = wf_result()['apiVersion'].split('/')
       k8s_co = k8s_client.CustomObjectsApi()
-      k8s_co.create_namespaced_custom_object(group=group, version=version, namespace=get_namespace(args), plural='workflows', body=wf_result)
+      k8s_co.create_namespaced_custom_object(group=group, version=version, namespace=get_namespace(args), plural='workflows', body=wf_result())
 
   # We delay creating started.json until we know the Argo workflow URLs
   create_started_file(args.bucket, ui_urls)