Как завершить задачу celery?

Question

[demortall]

def receive(self, text_data):
        data = json.loads(text_data)
        if data["do"] == "startScan":
            account = FaceitAccount.objects.filter(id=data["account_id"]).first()
            if account:
                task = startScan.delay(data, self.user.login, str(account.bearer))
                self.task = task
                self.user.task_id = task.task_id
                self.user.save()
        elif data['do'] == 'finishScan':
            self.task.revoke(terminate=True, signal='SIGKILL')
            self.send(str({"type": 'message_green',  'data': 'Скан завершён'}))

У меня запускается celery задача через сайт в котором есть многопоточность и должно выключаться через кнопку.
Но оно не завершается

Comments

[Сергей Горностаев]

Что значит "в котором есть многопоточность через сайт"?

[demortall]

Сергей Горностаев, Запускается через сайт, а в задаче многопоточные задачи

[Сергей Горностаев]

demortall, а зачем? Ведь Celery - само по себе механизм многозадачности.

[demortall]

Сергей Горностаев, она нужна для скорости парсинга

[Сергей Горностаев]

demortall, проще и эффективнее распараллелить парсинг задачами Celery. В Python потоки - это всегда не лучшее решение, а особенно в случаях с Django.

[demortall]

Сергей Горностаев, тоесть мне создавать еще задачи селери с одного задачи селери?

[Сергей Горностаев]

demortall, ага.

[demortall]

Сергей Горностаев, спасибо