diff --git a/docs/CHANGELOG.md b/docs/CHANGELOG.md index 7e106d88..04d81ede 100644 --- a/docs/CHANGELOG.md +++ b/docs/CHANGELOG.md @@ -2,7 +2,7 @@ ## 0.13.0 -- deps: bump xqute to 0.3.0 and liquidpy to 0.8.2 +- deps: bump xqute to 0.3.1 and liquidpy to 0.8.2 - breaking: change hook `on_job_running` to `on_job_started` and add `on_job_polling` ## 0.12.5 diff --git a/examples/plugin-example.py b/examples/plugin-example.py index 5d27318e..34ec659a 100644 --- a/examples/plugin-example.py +++ b/examples/plugin-example.py @@ -29,10 +29,15 @@ async def on_proc_start(proc): async def on_proc_done(proc, succeeded): logger.info("Calling on_proc_done, succeeded = %s", succeeded) + @plugin.impl + async def on_job_polling(proc, job): + logger.info("Calling on_job_polling") + class AProcess(Proc): input = "a" + script = 'sleep 2' if __name__ == "__main__": - Pipen(plugins=[NotifyPlugin]).set_starts(AProcess).run() + Pipen(plugins=[NotifyPlugin], cache=False).set_starts(AProcess).run() diff --git a/poetry.lock b/poetry.lock index 5fc69717..05624229 100644 --- a/poetry.lock +++ b/poetry.lock @@ -524,6 +524,16 @@ files = [ {file = "MarkupSafe-2.1.3-cp311-cp311-musllinux_1_1_x86_64.whl", hash = "sha256:5bbe06f8eeafd38e5d0a4894ffec89378b6c6a625ff57e3028921f8ff59318ac"}, {file = "MarkupSafe-2.1.3-cp311-cp311-win32.whl", hash = "sha256:dd15ff04ffd7e05ffcb7fe79f1b98041b8ea30ae9234aed2a9168b5797c3effb"}, {file = "MarkupSafe-2.1.3-cp311-cp311-win_amd64.whl", hash = "sha256:134da1eca9ec0ae528110ccc9e48041e0828d79f24121a1a146161103c76e686"}, + {file = "MarkupSafe-2.1.3-cp312-cp312-macosx_10_9_universal2.whl", hash = "sha256:f698de3fd0c4e6972b92290a45bd9b1536bffe8c6759c62471efaa8acb4c37bc"}, + {file = "MarkupSafe-2.1.3-cp312-cp312-macosx_10_9_x86_64.whl", hash = "sha256:aa57bd9cf8ae831a362185ee444e15a93ecb2e344c8e52e4d721ea3ab6ef1823"}, + {file = "MarkupSafe-2.1.3-cp312-cp312-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:ffcc3f7c66b5f5b7931a5aa68fc9cecc51e685ef90282f4a82f0f5e9b704ad11"}, + {file = "MarkupSafe-2.1.3-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:47d4f1c5f80fc62fdd7777d0d40a2e9dda0a05883ab11374334f6c4de38adffd"}, + {file = "MarkupSafe-2.1.3-cp312-cp312-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:1f67c7038d560d92149c060157d623c542173016c4babc0c1913cca0564b9939"}, + {file = "MarkupSafe-2.1.3-cp312-cp312-musllinux_1_1_aarch64.whl", hash = "sha256:9aad3c1755095ce347e26488214ef77e0485a3c34a50c5a5e2471dff60b9dd9c"}, + {file = "MarkupSafe-2.1.3-cp312-cp312-musllinux_1_1_i686.whl", hash = "sha256:14ff806850827afd6b07a5f32bd917fb7f45b046ba40c57abdb636674a8b559c"}, + {file = "MarkupSafe-2.1.3-cp312-cp312-musllinux_1_1_x86_64.whl", hash = "sha256:8f9293864fe09b8149f0cc42ce56e3f0e54de883a9de90cd427f191c346eb2e1"}, + {file = "MarkupSafe-2.1.3-cp312-cp312-win32.whl", hash = "sha256:715d3562f79d540f251b99ebd6d8baa547118974341db04f5ad06d5ea3eb8007"}, + {file = "MarkupSafe-2.1.3-cp312-cp312-win_amd64.whl", hash = "sha256:1b8dd8c3fd14349433c79fa8abeb573a55fc0fdd769133baac1f5e07abf54aeb"}, {file = "MarkupSafe-2.1.3-cp37-cp37m-macosx_10_9_x86_64.whl", hash = "sha256:8e254ae696c88d98da6555f5ace2279cf7cd5b3f52be2b5cf97feafe883b58d2"}, {file = "MarkupSafe-2.1.3-cp37-cp37m-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:cb0932dc158471523c9637e807d9bfb93e06a95cbf010f1a38b98623b929ef2b"}, {file = "MarkupSafe-2.1.3-cp37-cp37m-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:9402b03f1a1b4dc4c19845e5c749e3ab82d5078d16a2a4c2cd2df62d57bb0707"}, @@ -1143,13 +1153,13 @@ files = [ [[package]] name = "xqute" -version = "0.3.0" +version = "0.3.1" description = "A job management system for python" optional = false python-versions = ">=3.8,<4.0" files = [ - {file = "xqute-0.3.0-py3-none-any.whl", hash = "sha256:11310a6c4c3b4e24c600562a0b80452fdb89b0eb28eaae0fe8841d579a82ad26"}, - {file = "xqute-0.3.0.tar.gz", hash = "sha256:a64950debf816d3356c2f6e0fe40441a26e8bb23629dc405f3d34a47a4d0a09d"}, + {file = "xqute-0.3.1-py3-none-any.whl", hash = "sha256:dd126a5e56d47bc8bdda4d10c316ba3b571e7d8f39b378e86b29bf28cfaed192"}, + {file = "xqute-0.3.1.tar.gz", hash = "sha256:544c4f93ebba14e9eb94c7292d2771dc9856eefe54ac83a1a48af5a83d76665d"}, ] [package.dependencies] @@ -1166,4 +1176,4 @@ uvloop = ">=0,<1" [metadata] lock-version = "2.0" python-versions = "^3.8" -content-hash = "332437a26052b7772034511b253bb90d5d78a80fd85e748aeaad6ac1994511b3" +content-hash = "485270843ea9a62c4187d7b9de1e66377c15eb5b124ea77bffebff328bacd5df" diff --git a/pyproject.toml b/pyproject.toml index cee96718..52e05ecf 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -21,7 +21,7 @@ liquidpy = "^0.8.2" pandas = "^2" enlighten = "^1" argx = "^0.2.10" -xqute = "^0.3.0" +xqute = "^0.3.1" ## included in xqute # rich = "^13" # diot = "^0.1"