🔖 0.6.0

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

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

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:

pipen/version.py

@@ -1,3 +1,3 @@
 """Provide version of pipen"""
 
-__version__ = "0.5.2"
+__version__ = "0.6.0"

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 <[email protected]>",]
 license = "MIT"