Comments (6)
You should be able to terminate workers mid-processing. RabbitMQ will automatically re-queue the tasks and redistribute them to whatever workers are left online.
from tork.
I know, but let's image that in one task I have some x200 sub tasks - like downloading\uploading something and I dont want to terminate this. I just want to let those tasks finish and the rest become onhold
from tork.
They will finish. It's not going to restart the parent task. Each of the subtasks will get auto requeued. Those that finish will not be impacted.
from tork.
Ok, let me rephrase:
I want to download 1m urls > I split this job to 1000 parallel tasks > and inside each task I have 1k urls
I have 100 workers. During the run of each task I have finished, lets image, 500 tasks in this Job. If I stop this Job all tasks will be marked as Canceled
and if I Restart
this Job - Tork will run all tasks that already Completed
- 500 tasks already completed and I don't want to re-run them.
So thats why I dont want to re-run completed tasks inside Job with parallel tasks.
from tork.
Simply don't stop/cancel the job. Let it run. Terminate whatever machines you like, any tasks on these machines will be requeued to be handled by other workers.
from tork.
So long as RabbitMQ stays online you should be fine with doing whatever you want with the workers and even the coordinator
from tork.
Related Issues (20)
- Prune old nodes HOT 3
- [bug] entrypoint can't find script inside HOT 1
- RUNNING state change not shown on middleware HOT 1
- Pre/Post task evaluate issue when used with job middleware HOT 3
- Feature Request: support allowing custom headers in webhooks HOT 1
- feature request: Download all logs for a job HOT 6
- Option to delete old jobs HOT 2
- Task container port mapping HOT 11
- quality of life: when duplicate a job, don't redact environment variables in task if it inherit from input HOT 3
- Like how simple this application is. How to contribute? HOT 3
- Support of recurring jobs
- Passing in JSON through task output HOT 1
- request: make get log max page size configurable HOT 2
- request: disable logging HOT 11
- Tork worker inside script doesn't see host env vars HOT 8
- Setting task working dirs
- Kicking jobs off with arbitrary data HOT 2
- Setting job failed state in Job HandlerFunc HOT 2
- Jobs with Parallel, Each, and SubJobs HOT 1
- Custom Mounter for docker HOT 5
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 tork.