Skip to content

Commit a63f4c9

Browse files
committed
Fix logging function
1 parent 1399811 commit a63f4c9

2 files changed

Lines changed: 18 additions & 11 deletions

File tree

src/ephemeris/generate_tool_list_from_ga_workflow_files.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ def translate_workflow_dictionary_to_tool_list(
7878
)
7979
tool_list: List[InstallRepoDict] = []
8080
for tool in starting_tool_list:
81-
sub_dic = {
81+
sub_dic: InstallRepoDict = {
8282
"name": tool["name"],
8383
"owner": tool["owner"],
8484
"revisions": [tool["changeset_revision"]],

src/ephemeris/shed_tools.py

Lines changed: 17 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -516,17 +516,24 @@ def register(job_data):
516516

517517
executor.submit(run_test, test_index, test_id)
518518

519-
def install_repository_revision(self, repository, log):
519+
def install_repository_revision(self, repository: InstallRepoDict, log):
520520
default_err_msg = (
521521
"All repositories that you are attempting to install "
522522
"have been previously installed."
523523
)
524524
start = dt.datetime.now()
525525
try:
526-
repository["new_tool_panel_section_label"] = repository.pop(
527-
"tool_panel_section_label"
526+
response = self.tool_shed_client.install_repository_revision(
527+
tool_shed_url=repository["tool_shed_url"],
528+
name=repository["name"],
529+
owner=repository["owner"],
530+
changeset_revision=repository["changeset_revision"],
531+
install_tool_dependencies=repository["install_tool_dependencies"],
532+
install_repository_dependencies=repository["install_repository_dependencies"],
533+
install_resolver_dependencies=repository["install_resolver_dependencies"],
534+
new_tool_panel_section_label=repository.get("tool_panel_section_label"),
535+
tool_panel_section_id=repository.get("tool_panel_section_id"),
528536
)
529-
response = self.tool_shed_client.install_repository_revision(**repository)
530537
if isinstance(response, dict) and response.get("status", None) == "ok":
531538
# This rare case happens if a repository is already installed but
532539
# was not recognised as such in the above check. In such a
@@ -572,13 +579,13 @@ def install_repository_revision(self, repository, log):
572579
else:
573580
if log:
574581
log_repository_install_error(
575-
repository=repository, start=start, msg=e.body, log=log
582+
repository=repository, start=start, msg=getattr(e, "body", unicodify(e)), log=log
576583
)
577584
return "error"
578585
else:
579586
if log:
580587
log_repository_install_error(
581-
repository=repository, start=start, msg=e.body, log=log
588+
repository=repository, start=start, msg=getattr(e, "body", unicodify(e)), log=log
582589
)
583590
return "error"
584591

@@ -696,7 +703,7 @@ def log_repository_install_skip(repository, counter, total_num_repositories, log
696703

697704

698705
def log_repository_install_start(
699-
repository, counter, total_num_repositories, installation_start, log
706+
repository: InstallRepoDict, counter, total_num_repositories, installation_start, log
700707
):
701708
log.debug(
702709
'(%s/%s) Installing repository %s from %s to section "%s" at revision %s (TRT: %s)'
@@ -705,9 +712,9 @@ def log_repository_install_start(
705712
total_num_repositories,
706713
repository["name"],
707714
repository["owner"],
708-
repository["tool_panel_section_id"]
709-
or repository["tool_panel_section_label"],
710-
repository["changeset_revision"],
715+
repository.get("tool_panel_section_id")
716+
or repository.get("tool_panel_section_label"),
717+
repository.get("changeset_revision"),
711718
dt.datetime.now() - installation_start,
712719
)
713720
)

0 commit comments

Comments
 (0)