Skip to content

Commit

Permalink
Merge pull request galaxyproject#19140 from mvdbeek/destentation_typo…
Browse files Browse the repository at this point in the history
…_fix

Fix destentation typo
  • Loading branch information
nsoranzo authored Nov 14, 2024
2 parents 6a017b9 + 9f1284b commit ff9470e
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions lib/galaxy/jobs/runners/pulsar.py
Original file line number Diff line number Diff line change
Expand Up @@ -1015,7 +1015,7 @@ class PulsarMQJobRunner(PulsarJobRunner):


DEFAULT_PULSAR_CONTAINER = "galaxy/pulsar-pod-staging:0.15.0.2"
COEXECUTION_DESTENTATION_DEFAULTS = {
COEXECUTION_DESTINATION_DEFAULTS = {
"default_file_action": "remote_transfer",
"rewrite_parameters": "true",
"jobs_directory": "/pulsar_staging",
Expand All @@ -1027,7 +1027,7 @@ class PulsarMQJobRunner(PulsarJobRunner):


class PulsarCoexecutionJobRunner(PulsarMQJobRunner):
destination_defaults = COEXECUTION_DESTENTATION_DEFAULTS
destination_defaults = COEXECUTION_DESTINATION_DEFAULTS

def _populate_parameter_defaults(self, job_destination):
super()._populate_parameter_defaults(job_destination)
Expand All @@ -1041,22 +1041,22 @@ def _populate_parameter_defaults(self, job_destination):
pulsar_app_config["staging_directory"] = params.get("jobs_directory")


KUBERNETES_DESTINATION_DEFAULTS: Dict[str, Any] = {"k8s_enabled": True, **COEXECUTION_DESTENTATION_DEFAULTS}
KUBERNETES_DESTINATION_DEFAULTS: Dict[str, Any] = {"k8s_enabled": True, **COEXECUTION_DESTINATION_DEFAULTS}


class PulsarKubernetesJobRunner(PulsarCoexecutionJobRunner):
destination_defaults = KUBERNETES_DESTINATION_DEFAULTS
poll = True # Poll so we can check API for pod IP for ITs.


TES_DESTENTATION_DEFAULTS: Dict[str, Any] = {
TES_DESTINATION_DEFAULTS: Dict[str, Any] = {
"tes_url": PARAMETER_SPECIFICATION_REQUIRED,
**COEXECUTION_DESTENTATION_DEFAULTS,
**COEXECUTION_DESTINATION_DEFAULTS,
}


class PulsarTesJobRunner(PulsarCoexecutionJobRunner):
destination_defaults = TES_DESTENTATION_DEFAULTS
destination_defaults = TES_DESTINATION_DEFAULTS


class PulsarRESTJobRunner(PulsarJobRunner):
Expand Down

0 comments on commit ff9470e

Please sign in to comment.