workflow
workflow copied to clipboard
nirmata
A ZooKeeper and Curator based distributed workflow management library that enables distributed task workflows.
Implement direct submission of tasks to Kafka. UT is yet to be done.
Hi Jordan Zimmerman, Adding "Graceful shutdown" feature, kindly review. If it seems fine, please accept the pull request. Thanks & Regards, Rajesh.
Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.12.1 to 2.13.4.1. Commits See full diff in compare view [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Use case: Suppose we have a fleet of workflow task executor instances picking tasks continuously submitted by the leader node. The tasks in nature can be time taking ones. Now...
Use case: Suppose we have a fleet of workflow task executor instances picking tasks continuously submitted by the leader node. The tasks in nature can be time taking ones. Now...
I'm very new to ZK/Curator and was just executing [your example](http://nirmata.github.io/workflow/example.html). It seems that your SchedulerSelector tries to take leadership after curator is closed. May be a proper closing of...
Getting the following NPE while executing [your example](http://nirmata.github.io/workflow/example.html): ``` 2023-09-12 09:40:32,831 ERROR org.apache.curator.framework.recipes.cache.PathChildrenCache [Curator-PathChildrenCache-0] - java.lang.NullPointerException: Cannot invoke "org.apache.curator.framework.recipes.cache.ChildData.getPath()" because the return value of "org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent.getData()" is null at com.nirmata.workflow.details.WorkflowListenerManagerImpl.lambda$start$0(WorkflowListenerManagerImpl.java:48) ~[nirmata-workflow-0.9.7.jar:?]...
Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.12.1 to 2.12.7.1. Commits See full diff in compare view [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter...