Skip to content

Commit

Permalink
WIP: make add_new_graph and resolve_duplicates private methods and re…
Browse files Browse the repository at this point in the history
…quire user to pass graphs in order
  • Loading branch information
eigerx committed Sep 14, 2024
1 parent e2c5d9d commit 108d5a7
Showing 1 changed file with 5 additions and 12 deletions.
17 changes: 5 additions & 12 deletions python/lsst/ctrl/mpexec/cli/script/report.py
Original file line number Diff line number Diff line change
Expand Up @@ -170,18 +170,11 @@ def report_v2(
butler = Butler.from_config(butler_config, writeable=False)
qpg = QuantumProvenanceGraph()
output_runs = []

Check failure on line 172 in python/lsst/ctrl/mpexec/cli/script/report.py

View workflow job for this annotation

GitHub Actions / call-workflow / lint

F841

local variable 'output_runs' is assigned to but never used
for qgraph_uri in qgraph_uris:
qgraph = QuantumGraph.loadUri(qgraph_uri)
qpg.add_new_graph(butler, qgraph)
output_runs.append(qgraph.metadata["output_run"])
collections_sequence: Sequence[Any] # to appease mypy
if not collections:
collections_sequence = list(reversed(output_runs))
else:
collections_sequence = collections
qpg.resolve_duplicates(
butler, collections=collections_sequence, where=where, curse_failed_logs=curse_failed_logs
)
qgraphs = [QuantumGraph.loadUri(qgraph_uri) for qgraph_uri in qgraph_uris]
# for qgraph_uri in qgraph_uris:
# qgraphs.append(QuantumGraph.loadUri(qgraph_uri))
qpg.assemble_quantum_provenance_graph(butler, qgraphs, collections, where,
curse_failed_logs)
summary = qpg.to_summary(butler, do_store_logs=logs)
print_summary(summary, full_output_filename, brief)

Expand Down

0 comments on commit 108d5a7

Please sign in to comment.