Skip to content

Commit

Permalink
fixes lint errors
Browse files Browse the repository at this point in the history
  • Loading branch information
markjschreiber committed Sep 26, 2024
1 parent 08be0fb commit c22f22c
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions omics/cli/run_analyzer/__main__.py
Original file line number Diff line number Diff line change
Expand Up @@ -446,7 +446,7 @@ def get_timeline_event(res, resources):

# Retrieve workflow runs & tasks
runs = []
resources = []
resources: list[dict]
if opts["--file"]:
with open(opts["--file"]) as f:
resources = json.load(f)
Expand All @@ -459,15 +459,15 @@ def get_timeline_event(res, resources):
if not runs:
die("no matching workflow runs")

if len(runs) == 1 and opts["<runId>"]:
elif len(runs) == 1 and opts["<runId>"]:
resources = get_run_resources(logs, runs[0])
if not resources:
die("no workflow run resources")
if len(runs) >= 1 and opts["--batch"]:
list_of_resources: list[list[dict]] = []
engine: str = None
for run in runs:
resources: list[dict] = get_run_resources(logs, run)
resources = get_run_resources(logs, run)
run_engine = utils.get_engine_from_id(id=run)
if not engine:
engine = run_engine
Expand Down
2 changes: 1 addition & 1 deletion omics/cli/run_analyzer/batch.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ def aggregate_and_print(
# print hdrs
print(",".join(hdrs), file=out)

task_names = sorted(task_names)
task_names = set(sorted(task_names))
for task_name in task_names:
_aggregate_resources(run_resources_list, task_name, engine, out)

Expand Down

0 comments on commit c22f22c

Please sign in to comment.