From bcfd81953b3feeaac6669a3487cc1eab3d5a2727 Mon Sep 17 00:00:00 2001 From: Johannes Koester Date: Tue, 16 Jan 2024 10:03:50 +0000 Subject: [PATCH] feat: add ability to pass group args to remote jobs --- snakemake_interface_executor_plugins/cli.py | 1 + snakemake_interface_executor_plugins/executors/real.py | 1 + snakemake_interface_executor_plugins/settings.py | 1 + 3 files changed, 3 insertions(+) diff --git a/snakemake_interface_executor_plugins/cli.py b/snakemake_interface_executor_plugins/cli.py index 64048dc..624e91d 100644 --- a/snakemake_interface_executor_plugins/cli.py +++ b/snakemake_interface_executor_plugins/cli.py @@ -8,6 +8,7 @@ def general_args( self, pass_default_storage_provider_args: bool = True, pass_default_resources_args: bool = False, + pass_group_args: bool = False, ) -> str: ... diff --git a/snakemake_interface_executor_plugins/executors/real.py b/snakemake_interface_executor_plugins/executors/real.py index 98e8f4f..f5fb060 100644 --- a/snakemake_interface_executor_plugins/executors/real.py +++ b/snakemake_interface_executor_plugins/executors/real.py @@ -151,6 +151,7 @@ def format_job_exec(self, job: JobExecutorInterface) -> str: general_args = self.workflow.spawned_job_args_factory.general_args( pass_default_storage_provider_args=self.common_settings.pass_default_storage_provider_args, pass_default_resources_args=self.common_settings.pass_default_resources_args, + pass_group_args=self.common_settings.pass_group_args, ) precommand = self.workflow.spawned_job_args_factory.precommand( auto_deploy_default_storage_provider=self.common_settings.auto_deploy_default_storage_provider diff --git a/snakemake_interface_executor_plugins/settings.py b/snakemake_interface_executor_plugins/settings.py index 56083ed..6b0b981 100644 --- a/snakemake_interface_executor_plugins/settings.py +++ b/snakemake_interface_executor_plugins/settings.py @@ -59,6 +59,7 @@ class CommonSettings: pass_envvar_declarations_to_cmd: bool = True auto_deploy_default_storage_provider: bool = True init_seconds_before_status_checks: int = 0 + pass_group_args: bool = False @property def local_exec(self):