Skip to content

Commit

Permalink
fix: adapt to changes in snakemake-interface-executor-plugins
Browse files Browse the repository at this point in the history
  • Loading branch information
johanneskoester committed Sep 20, 2023
1 parent 3f6b66f commit e73f71d
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,8 @@ readme = "README.md"

[tool.poetry.dependencies]
python = "^3.9"
snakemake-interface-common = "^1.3.2"
snakemake-interface-executor-plugins = "^3.0.0"
snakemake-interface-common = "^1.4.1"
snakemake-interface-executor-plugins = "^4.0.0"
snakemake-executor-plugin-slurm-jobstep = "^0.1.0"
throttler = "^1.2.2"

Expand Down
8 changes: 4 additions & 4 deletions snakemake_executor_plugin_slurm/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
from snakemake_interface_executor_plugins.workflow import WorkflowExecutorInterface
from snakemake_interface_executor_plugins.logging import LoggerExecutorInterface
from snakemake_interface_executor_plugins.jobs import (
ExecutorJobInterface,
JobExecutorInterface,
)
from snakemake_interface_common.exceptions import WorkflowError
from throttler import Throttler
Expand Down Expand Up @@ -74,7 +74,7 @@ def additional_general_args(self):
# SLURM jobsteps.
return "--slurm-jobstep --jobs 1"

def run_job(self, job: ExecutorJobInterface):
def run_job(self, job: JobExecutorInterface):
# Implement here how to run a job.
# You can access the job's resources, etc.
# via the job object.
Expand Down Expand Up @@ -366,7 +366,7 @@ async def job_stati(self, command):

return (res, query_duration)

def get_account_arg(self, job: ExecutorJobInterface):
def get_account_arg(self, job: JobExecutorInterface):
"""
checks whether the desired account is valid,
returns a default account, if applicable
Expand All @@ -393,7 +393,7 @@ def get_account_arg(self, job: ExecutorJobInterface):
)
return self._fallback_account_arg

def get_partition_arg(self, job: ExecutorJobInterface):
def get_partition_arg(self, job: JobExecutorInterface):
"""
checks whether the desired partition is valid,
returns a default partition, if applicable
Expand Down

0 comments on commit e73f71d

Please sign in to comment.