Skip to content

Commit

Permalink
black formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
jan-janssen committed Nov 26, 2023
1 parent 89bef3b commit 699d24f
Show file tree
Hide file tree
Showing 4 changed files with 11 additions and 11 deletions.
2 changes: 1 addition & 1 deletion pysqa/executor/executor.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
4 changes: 2 additions & 2 deletions pysqa/ext/modular.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ def submit_job(
run_time_max=None,
dependency_list=None,
command=None,
**kwargs
**kwargs,
):
"""
Expand All @@ -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(
Expand Down
4 changes: 2 additions & 2 deletions pysqa/queueadapter.py
Original file line number Diff line number Diff line change
Expand Up @@ -148,7 +148,7 @@ def submit_job(
run_time_max=None,
dependency_list=None,
command=None,
**kwargs
**kwargs,
):
"""
Submits command to the given queue.
Expand Down Expand Up @@ -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):
Expand Down
12 changes: 6 additions & 6 deletions pysqa/utils/basic.py
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ def submit_job(
run_time_max=None,
dependency_list=None,
command=None,
**kwargs
**kwargs,
):
"""
Expand Down Expand Up @@ -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(
Expand Down Expand Up @@ -337,7 +337,7 @@ def _write_queue_script(
memory_max=None,
run_time_max=None,
command=None,
**kwargs
**kwargs,
):
"""
Expand All @@ -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)
Expand All @@ -381,7 +381,7 @@ def _job_submission_template(
memory_max=None,
run_time_max=None,
command=None,
**kwargs
**kwargs,
):
"""
Expand Down Expand Up @@ -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(
Expand Down

0 comments on commit 699d24f

Please sign in to comment.