Comments (6)
You are in control of submitting new tasks. So, you could just stop submitting new tasks and then use the admin APIs to watch for current tasks to finish. Does that work for you?
from workflow.
Thank you for response.
In my use case, there are set of workflow instances running. I wanted to take down one instance without affecting other workflow instance.
I can very well kill that instance I wanted to take down, according to Nirmata's design other instances will pick-up running tasks(if idempotent) automatically.
But, in my case, these tasks are very time consuming ones, so I don't want to terminate them abnormally. So I was looking for any other ways to tell workflow manager to stop listening to new tasks, then I can wait till completion of already running tasks and terminate that instance.
Thank you again.
from workflow.
OK - it's definitely possible. I don't have time to do it right now. I'd appreciate a PR or I'll get to it when I can.
from workflow.
I forked the project, will add the feature of stopping workflow gracefully in workflowmanager API.
Before I start, could you please tell me, if any thing I need to know.
Thank you.
from workflow.
You'd:
- Add an API to
WorkflowManager
- something likegracefulShutdown(maxWait)
- The main work is in
SimpleQueue
- Call shutdown on the executorService then awaitTermination
Something like that
from workflow.
Thank you for the quick response, will send pull request once done with that.
from workflow.
Related Issues (20)
- A child task can submit its ancestor after a delay HOT 4
- Pluggable serialization HOT 1
- Providing more debugging for the scheduler
- uneven workflow distribution HOT 4
- scheduling of workflow stopped working HOT 4
- New feature request - Allow custom workflow task executors HOT 4
- workflowManager.getRunInfo() take a long time to complete HOT 15
- Potential thread leak HOT 5
- New feature request - workflow diagnostics HOT 9
- JsonSerializer.getTask() is not visible HOT 2
- Upgrade to Curator 3.2.0
- Use ZK container nodes wherever possible
- Scheduler stops receiving events from PathChildrenCache when associated ZK path was deleted and later recreated HOT 8
- Long running Idempotent task keeps creating watches and leads to Out Of Memory issues HOT 7
- NPE in WorkflowListenerManagerImpl at line 48 on event type CONNECTION_RECONNECTED with data = null
- SchedulerSelector throws IllegalStateException on exiting the runLoop HOT 1
- Closing/shutting down workflow instance one by one gracefully HOT 1
- Need a way to retrieve the metadata of a task submitted but not executed HOT 4
- mvn clean install command failing to execute HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from workflow.