From 699d24f5213cdd88656b5c93b4fa394869c7920b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jan=20Jan=C3=9Fen?= Date: Sun, 26 Nov 2023 20:47:09 +0100 Subject: [PATCH] black formatting --- pysqa/executor/executor.py | 2 +- pysqa/ext/modular.py | 4 ++-- pysqa/queueadapter.py | 4 ++-- pysqa/utils/basic.py | 12 ++++++------ 4 files changed, 11 insertions(+), 11 deletions(-) diff --git a/pysqa/executor/executor.py b/pysqa/executor/executor.py index fd99bee..1f6e908 100644 --- a/pysqa/executor/executor.py +++ b/pysqa/executor/executor.py @@ -31,7 +31,7 @@ def __init__(self, cwd=None, queue_adapter=None, queue_adapter_kwargs=None): self._queue_id = self._queue_adapter.submit_job( working_directory=self._cache_directory, command=command, - **queue_adapter_kwargs + **queue_adapter_kwargs, ) self._process = RaisingThread( target=find_executed_tasks, diff --git a/pysqa/ext/modular.py b/pysqa/ext/modular.py index 6beec53..3036bc7 100644 --- a/pysqa/ext/modular.py +++ b/pysqa/ext/modular.py @@ -34,7 +34,7 @@ def submit_job( run_time_max=None, dependency_list=None, command=None, - **kwargs + **kwargs, ): """ @@ -59,7 +59,7 @@ def submit_job( memory_max=memory_max, run_time_max=run_time_max, command=command, - **kwargs + **kwargs, ) cluster_module = self._queue_to_cluster_dict[queue] commands = self._switch_cluster_command( diff --git a/pysqa/queueadapter.py b/pysqa/queueadapter.py index aca30f2..95dd7c4 100644 --- a/pysqa/queueadapter.py +++ b/pysqa/queueadapter.py @@ -148,7 +148,7 @@ def submit_job( run_time_max=None, dependency_list=None, command=None, - **kwargs + **kwargs, ): """ Submits command to the given queue. @@ -178,7 +178,7 @@ def submit_job( run_time_max=run_time_max, dependency_list=dependency_list, command=command, - **kwargs + **kwargs, ) def enable_reservation(self, process_id): diff --git a/pysqa/utils/basic.py b/pysqa/utils/basic.py index 8e27da0..ad8696c 100644 --- a/pysqa/utils/basic.py +++ b/pysqa/utils/basic.py @@ -139,7 +139,7 @@ def submit_job( run_time_max=None, dependency_list=None, command=None, - **kwargs + **kwargs, ): """ @@ -168,7 +168,7 @@ def submit_job( memory_max=memory_max, run_time_max=run_time_max, command=command, - **kwargs + **kwargs, ) out = self._execute_command( commands=self._list_command_to_be_executed( @@ -337,7 +337,7 @@ def _write_queue_script( memory_max=None, run_time_max=None, command=None, - **kwargs + **kwargs, ): """ @@ -363,7 +363,7 @@ def _write_queue_script( memory_max=memory_max, run_time_max=run_time_max, command=command, - **kwargs + **kwargs, ) if not os.path.exists(working_directory): os.makedirs(working_directory) @@ -381,7 +381,7 @@ def _job_submission_template( memory_max=None, run_time_max=None, command=None, - **kwargs + **kwargs, ): """ @@ -423,7 +423,7 @@ def _job_submission_template( memory_max=memory_max, run_time_max=run_time_max, command=command, - **kwargs + **kwargs, ) def _execute_command(