django-celery - Celery 任务在本地运行时在正常关闭时重新排队到代理，但尽管配置相同但在 kubernetes 中丢失

Question

我有一个在 k8 pod 中运行的芹菜。这是我的芹菜清单

apiVersion: apps/v1
kind: Deployment
metadata:
  name: celery
  labels:
    deployment: celery
spec:
  replicas: 2
  selector:
    matchLabels:
      pod: celery
  template:
    metadata:
      labels:
        pod: celery
    spec:
      containers:
        - name: celery
          image: local_celery:latest
          imagePullPolicy: Never
          command: ['celery', '-A', 'proj', 'worker', '-E', '-l', 'info',]
          resources:
            limits:
              cpu: 50m
            requests:
              cpu: 50m

      terminationGracePeriodSeconds: 25

我在 django settings.py 中的 Celery 配置是

CELERY_TASK_ACKS_LATE = True
CELERY_WORKER_PREFETCH_MULTIPLIER = 1
CELERY_BROKER_URL = 'redis://redis:6379'
CELERY_RESULT_BACKEND = 'django-db'
CELERY_WORKER_CONCURRENCY=1
CEELERY_TASK_REJECT_ON_WORKER_LOST=True

ctrl-C当我使用 celery 和 redis 作为消息代理运行一个简单的 django 应用程序时，当我为工作人员启动热关机时，我的任务会重新排队到代理中。但是，当同一个应用程序部署到 celery、django 和 redis 在 3 个不同 pod 中运行的 kubernetes 时，当 celery pod 正常终止时，我的任务不会重新排队回到 redis。我无法理解为什么？我的芹菜设置在这两种情况下都没有改变。