SDK - Compiler - Validating Argo validator (#3874)

* SDK - Compiler - Validating Argo validator

* Added warning if argo is available, but not working

sdk/python/kfp/compiler/compiler.py

@@ -986,6 +986,22 @@ def _validate_workflow(workflow: dict):
 Please create a new issue at https://github.com/kubeflow/pipelines/issues attaching the pipeline code and the pipeline package.'''
     )
 
+  # Running Argo lint if available
+  import shutil
+  import subprocess
+  argo_path = shutil.which('argo')
+  if argo_path:
+    has_working_argo_lint = False
+    try:
+      has_working_argo_lint = _run_argo_lint('')
+    except:
+      warnings.warn("Cannot validate the compiled workflow. Found the argo program in PATH, but it's not usable. argo v2.4.3 should work.")
+
+    if has_working_argo_lint:
+      _run_argo_lint(yaml_text)
+
+
+def _run_argo_lint(yaml_text: str):
   # Running Argo lint if available
   import shutil
   import subprocess
@@ -998,3 +1014,5 @@ def _validate_workflow(workflow: dict):
 Please create a new issue at https://github.com/kubeflow/pipelines/issues attaching the pipeline code and the pipeline package.
 Error: {}'''.format(result.stderr.decode('utf-8'))
       )
+    return True
+  return False