lint fixes

Signed-off-by: shalberd <21118431+shalberd@users.noreply.github.com>
elyra-ai · Aug 16, 2024 · 007d392 · 007d392
1 parent f51d377
commit 007d392
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 5 deletions.
diff --git a/elyra/airflow/bootstrapper.py b/elyra/airflow/bootstrapper.py
@@ -40,7 +40,8 @@
 
 logger = logging.getLogger("elyra")
 enable_pipeline_info = os.getenv("ELYRA_ENABLE_PIPELINE_INFO", "true").lower() == "true"
-# not only log File Operations output of NotebookFileOp, RFileOp, PythonFileOp to stdout so it appears in runtime / container logs and also Airflow and KFP GUI logs, but also put output to S3 storage 
+# not only log File Operations output of NotebookFileOp, RFileOp, PythonFileOp to stdout so it appears in runtime / container logs
+# and also Airflow and KFP GUI logs, but also put output to S3 storage
 enable_generic_node_script_output_to_s3 = os.getenv("ELYRA_GENERIC_NODES_ENABLE_SCRIPT_OUTPUT_TO_S3", "true").lower() == "true"
 pipeline_name = None  # global used in formatted logging
 operation_name = None  # global used in formatted logging
@@ -574,7 +575,9 @@ def main():
     input_params = OpUtil.parse_arguments(sys.argv[1:])
     OpUtil.log_operation_info("starting operation")
     t0 = time.time()
-    OpUtil.package_install() # must be commented out in airgapped images if packages from https://github.com/elyra-ai/elyra/blob/main/etc/generic/requirements-elyra.txt already installed via central pip env during container build
+    # must be commented out in airgapped images if packages from https://github.com/elyra-ai/elyra/blob/main/etc/generic/requirements-elyra.txt
+    # already installed via central pip env during container build
+    OpUtil.package_install()
 
     # Create the appropriate instance, process dependencies and execute the operation
     file_op = FileOpBase.get_instance(**input_params)

diff --git a/elyra/kfp/bootstrapper.py b/elyra/kfp/bootstrapper.py
@@ -46,7 +46,8 @@
 
 logger = logging.getLogger("elyra")
 enable_pipeline_info = os.getenv("ELYRA_ENABLE_PIPELINE_INFO", "true").lower() == "true"
-# not only log File Operations output of NotebookFileOp, RFileOp, PythonFileOp to stdout so it appears in runtime / container logs and also Airflow and KFP GUI logs, but also put output to S3 storage 
+# not only log File Operations output of NotebookFileOp, RFileOp, PythonFileOp to stdout so it appears in runtime / container logs
+# and also Airflow and KFP GUI logs, but also put output to S3 storage
 enable_generic_node_script_output_to_s3 = os.getenv("ELYRA_GENERIC_NODES_ENABLE_SCRIPT_OUTPUT_TO_S3", "true").lower() == "true"
 pipeline_name = None  # global used in formatted logging
 operation_name = None  # global used in formatted logging
@@ -757,8 +758,10 @@ def main():
     input_params = OpUtil.parse_arguments(sys.argv[1:])
     OpUtil.log_operation_info("starting operation")
     t0 = time.time()
-    OpUtil.package_install(user_volume_path=input_params.get("user-volume-path")) # must be commented out in airgapped images if packages from https://github.com/elyra-ai/elyra/blob/main/etc/generic/requirements-elyra.txt already installed via central pip env during container build
-
+    # must be commented out in airgapped images if packages from https://github.com/elyra-ai/elyra/blob/main/etc/generic/requirements-elyra.txt
+    # already installed via central pip env during container build
+    OpUtil.package_install(user_volume_path=input_params.get("user-volume-path"))
+
     # Create the appropriate instance, process dependencies and execute the operation
     file_op = FileOpBase.get_instance(**input_params)