diff --git a/docs/CHANGELOG.md b/docs/CHANGELOG.md index 828a850d..0fb94b26 100644 --- a/docs/CHANGELOG.md +++ b/docs/CHANGELOG.md @@ -1,5 +1,9 @@ # Change Log +## 0.6.0 + +- ✨ Allow subclassing Pipen to create a pipeline (#151) + ## 0.5.2 - 📝 Refactor codebase: unify type annotations and import future features diff --git a/pipen/job.py b/pipen/job.py index 06557d95..3787a761 100644 --- a/pipen/job.py +++ b/pipen/job.py @@ -35,7 +35,7 @@ class Job(XquteJob, JobCaching): def __init__(self, *args: Any, **kwargs: Any) -> None: super().__init__(*args, **kwargs) - self.proc: "Proc" = None + self.proc: Proc = None self._output_types: Dict[str, str] = {} self._outdir = self.metadir / "output" @@ -244,7 +244,7 @@ def log( self.proc.log(level, job_index_indicator + msg, *args, logger=logger) - async def prepare(self, proc: "Proc") -> None: + async def prepare(self, proc: Proc) -> None: """Prepare the job by given process Primarily prepare the script, and provide cmd to the job for xqute diff --git a/pipen/pipen.py b/pipen/pipen.py index 528a73dd..804dae20 100644 --- a/pipen/pipen.py +++ b/pipen/pipen.py @@ -217,7 +217,7 @@ def run( """ return asyncio.run(self.async_run(profile)) - def set_data(self, *indata: Any) -> "Pipen": + def set_data(self, *indata: Any) -> Pipen: """Set the input_data for start processes Args: diff --git a/pipen/version.py b/pipen/version.py index efba4568..eeb5d607 100644 --- a/pipen/version.py +++ b/pipen/version.py @@ -1,3 +1,3 @@ """Provide version of pipen""" -__version__ = "0.5.2" +__version__ = "0.6.0" diff --git a/pyproject.toml b/pyproject.toml index abffc8f7..6da87a6a 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -4,7 +4,7 @@ build-backend = "poetry.masonry.api" [tool.poetry] name = "pipen" -version = "0.5.2" +version = "0.6.0" description = "A pipeline framework for python" authors = [ "pwwang ",] license = "MIT"