Skip to content

Commit

Permalink
feat(cli): changed variable name for failing pipeline
Browse files Browse the repository at this point in the history
  • Loading branch information
kevinkarchacryl committed Dec 3, 2024
1 parent a8ea78b commit f57dbab
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions metadata-ingestion/src/datahub/cli/ingest_cli.py
Original file line number Diff line number Diff line change
Expand Up @@ -515,17 +515,17 @@ def list_source_runs(page_offset: int, page_size: int, urn: str, source: str) ->
click.echo("No matching ingestion sources found. Please check your filters.")
return

sources = data["data"]["listIngestionSources"]["ingestionSources"]
if not sources:
ingestion_sources = data["data"]["listIngestionSources"]["ingestionSources"]
if not ingestion_sources:
click.echo("No ingestion sources or executions found.")
return

rows = []
for source in sources:
urn = source.get("urn", "N/A")
name = source.get("name", "N/A")
for ingestion_source in ingestion_sources:
urn = ingestion_source.get("urn", "N/A")
name = ingestion_source.get("name", "N/A")

executions = source.get("executions", {}).get("executionRequests", [])
executions = ingestion_source.get("executions", {}).get("executionRequests", [])
for execution in executions:
execution_id = execution.get("id", "N/A")
start_time = execution.get("result", {}).get("startTimeMs", "N/A")
Expand Down

0 comments on commit f57dbab

Please sign in to comment.