Skip to content

Commit

Permalink
Install repos for all tested artifacts
Browse files Browse the repository at this point in the history
  • Loading branch information
mvdbeek committed Feb 13, 2023
1 parent fd41051 commit b5a16ca
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 4 deletions.
7 changes: 3 additions & 4 deletions planemo/engine/galaxy.py
Original file line number Diff line number Diff line change
Expand Up @@ -47,10 +47,9 @@ class GalaxyEngine(BaseEngine, metaclass=abc.ABCMeta):
def _run(self, runnables, job_paths):
"""Run job in Galaxy."""
results = []
for runnable, job_path in zip(runnables, job_paths):
self._ctx.vlog(f"Serving artifact [{runnable}] with Galaxy.")
with self.ensure_runnables_served([runnable]) as config:
self._ctx.vlog(f"Running job path [{job_path}]")
with self.ensure_runnables_served(runnables) as config:
for runnable, job_path in zip(runnables, job_paths):
self._ctx.log(f"Running [{runnable}] - [{job_path}] with Galaxy.")
if self._ctx.verbose:
self._ctx.log(f"Running Galaxy with API configuration [{config.user_api_config}]")
run_response = execute(self._ctx, config, runnable, job_path, **self._kwds)
Expand Down
7 changes: 7 additions & 0 deletions planemo/galaxy/workflows.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,11 +27,18 @@

from planemo.galaxy.api import gi
from planemo.io import warn
from typing_extensions import NamedTuple


FAILED_REPOSITORIES_MESSAGE = "Failed to install one or more repositories."
GALAXY_WORKFLOWS_PREFIX = "gxid://workflows/"


class InstalledShedRepos(NamedTuple):
installed_repositories: List[InstallRepoDict]
updated_repositories: List[InstallRepoDict]


def load_shed_repos(runnable):
if runnable.type.name != "galaxy_workflow":
return []
Expand Down

0 comments on commit b5a16ca

Please sign in to comment.