0.6.2 (#153)

* ⬆️ Adopt xqute 0.1.5

* 📝 Update README.md

* 🔖 0.6.2

README.md

@@ -134,9 +134,11 @@ https://github.com/pwwang/pipen-report/tree/master/example
 Plugins make `pipen` even better.
 
 - [`pipen-verbose`][15]: Add verbosal information in logs for pipen.
+- [`pipen-lock`][25]: Process lock for pipen to prevent multiple runs at the same time.
 - [`pipen-report`][16]: Generate report for pipen
 - [`pipen-filters`][17]: Add a set of useful filters for pipen templates.
 - [`pipen-diagram`][18]: Draw pipeline diagrams for pipen
+- [`pipen-annotate`][26]: Use docstring to annotate pipen processes
 - [`pipen-args`][19]: Command line argument parser for pipen
 - [`pipen-dry`][20]: Dry runner for pipen pipelines
 - [`pipen-cli-init`][21]: A pipen CLI plugin to create a pipen project (pipeline)
@@ -168,3 +170,5 @@ Plugins make `pipen` even better.
 [22]: https://github.com/pwwang/pipen-cli-run
 [23]: https://libraries.io/github/pwwang/pipen#repository_dependencies
 [24]: https://github.com/pwwang/pipen-cli-require
+[25]: https://github.com/pwwang/pipen-lock
+[26]: https://github.com/pwwang/pipen-annotate

docs/CHANGELOG.md

@@ -1,5 +1,9 @@
 # Change Log
 
+## 0.6.2
+
+- ⬆️ Adopt xqute 0.1.5
+
 ## 0.6.1
 
 - 🐛 Fix path expansion for `~/.pipen.toml` in defaults.

pipen/job.py

@@ -130,7 +130,7 @@ def output(self) -> Mapping[str, Any]:
                 outdir=str(self.outdir),
                 stdout_file=str(self.stdout_file),
                 stderr_file=str(self.stderr_file),
-                lock_file=str(self.lock_file),
+                jid_file=str(self.jid_file),
             ),
             "in": self.input,
             "in_": self.input,
@@ -201,7 +201,7 @@ def template_data(self) -> Mapping[str, Any]:
                 outdir=str(self.outdir),
                 stdout_file=str(self.stdout_file),
                 stderr_file=str(self.stderr_file),
-                lock_file=str(self.lock_file),
+                jid_file=str(self.jid_file),
             ),
             "in": self.input,
             "in_": self.input,

pipen/progressbar.py

@@ -42,21 +42,28 @@ def update_job_retrying(self):
 
     def update_job_running(self):
         """Update the progress bar when a job is running"""
-        self.running_counter.update_from(self.submitted_counter)
+        try:
+            self.running_counter.update_from(self.submitted_counter)
+        except ValueError:  # pragma: no cover
+            pass
 
     def update_job_succeeded(self):
         """Update the progress bar when a job is succeeded"""
         try:
             self.success_counter.update_from(self.running_counter)
         except ValueError:  # pragma: no cover
             self.success_counter.update_from(self.submitted_counter)
+        except:  # noqa: E722  # pragma: no cover
+            pass
 
     def update_job_failed(self):
         """Update the progress bar when a job is failed"""
         try:
             self.failure_counter.update_from(self.running_counter)
         except ValueError:  # pragma: no cover
             self.failure_counter.update_from(self.submitted_counter)
+        except:  # noqa: E722  # pragma: no cover
+            pass
 
     def done(self):
         """The process is done"""

pipen/version.py

@@ -1,3 +1,3 @@
 """Provide version of pipen"""
 
-__version__ = "0.6.1"
+__version__ = "0.6.2"

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "poetry.masonry.api"
 
 [tool.poetry]
 name = "pipen"
-version = "0.6.1"
+version = "0.6.2"
 description = "A pipeline framework for python"
 authors = [ "pwwang <[email protected]>",]
 license = "MIT"