我正在运行一些戏剧作为kubernetes作业。如果队列中没有消息,则用例要求pod关闭。所以我需要的是,如果没有消息在队列中,那么剧作家进程关闭。
是否可以在戏剧中做到这一点?
您可以使用@dramatiq.actor(max_retries=-1)
装饰器,这将导致worker在处理完队列中的所有消息后退出