Comments (2)
In theory one can call Stop() on a server, then wait until that server has finished processing all it's tasks, then call Shutdown().
Yeah. But calling shutdown is enough as it will call processor.stop() internally (same as Stop()).
But I can't see how I can get the ID of the server I called Stop() on
Hmm. seems correct, the heartbeater doesn't log this info.
calling NewServer should yield a way to get a server ID
Would a debug log line be enough?
ideally, we'd have a way to GetServerInfo(serverID string)
At the inspector level? It could be possible.
from asynq.
Yeah. But calling shutdown is enough as it will call processor.stop() internally (same as Stop()).
In local testing Stop() doesn't seem to block though (apologies if I'm wrong here, I can check the code when I have time) -- if Stop() does block until it's finished processing everything it has then that's ok.
Would a debug log line be enough?
At the inspector level? It could be possible.
My idea here was that I could have something in my code that checks that the server has finished processing before allowing it to be killed -- so I'd want a way to get the ID in code that wraps the server.
from asynq.
Related Issues (20)
- [BUG] Running only 1 worked from 800 HOT 4
- How do I support multiple namespaces for a redis db HOT 1
- [GENERAL QUESTION] Status of this project? HOT 2
- [FEATURE REQUEST] Customize Queue Group Strategy.
- [QUESTION] Archived periodic tasks are not triggered on the scheduled run
- I
- How do I unregister my mux handler HOT 1
- How to add concurrency to a task ? HOT 1
- [QUESTION] How to delete tasks that have been archived and are not in the "asynq:{default}:archived" zset? HOT 2
- [FEATURE REQUEST] Support changing priority queues at runtime HOT 9
- Question : how to wait for results after enqueue HOT 1
- [FEATURE REQUEST] Dynamically Changing Concurrency Config Value? HOT 1
- Enqueue Failing
- UNKNOWN: redis command error: SADD failed: READONLY You can't write against a read only replica. HOT 2
- [FEATURE REQUEST] https://github.com/golang/protobuf is Depercated
- [FEATURE REQUEST] Support dynamic queue HOT 3
- [FEATURE REQUEST] stop usage of the internal folder
- When release v1? HOT 1
- How to mark a task as completed externally HOT 1
- Add example for redict.io and NATS jetstream 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 asynq.