Tag: celery-task

Sellerie-Aufgabe ist ein Baustein der Sellerie distributed task queue-system

Wie man eine Sellerie Aufgabe scheitern innerhalb der Aufgabe?

3 Antworten

Unter bestimmten Bedingungen, ich möchte eine Sellerie-Aufgabe nicht aus, dass innerhalb dieser Aufgabe. Ich habe versucht, die folgenden: from celery.task import task from celery import states @task() def run_simulation(): if some_condition: run_simulation.update_state(state=states.FAILURE) return False Jedoch die Aufgabe

celery celery-task

so entfernen Sie den task aus Sellerie mit redis broker?

3 Antworten

Ich Habe fügen Sie einige falsche task zu einem celery mit redis broker aber das will ich jetzt entfernen Sie die falsche task und ich finde keine Möglichkeit, dies zu tun Gibt es einige Befehle oder einige

Sellerie AttributeError: async-error

6 Antworten

Ich habe RabbitMQ und Sellerie läuft lokal auf meinem Mac (OS/X 10.13.4), der folgende code funktioniert lokal bei mir laufen hinzufügen.Verzögerung(x,y): #!/usr/bin/env python from celery import Celery from celery.utils.log import get_task_logger logger = get_task_logger(__name__) app = Celery('tasks',

celery celery-task python

läuft Sellerie als daemon mit Vorgesetzten nicht arbeiten

3 Antworten

Habe ich eine django-app, in der es eine Sellerie-Funktionalität, so kann ich in der Lage zu laufen, den Sellerie erfolgreich wie unten celery -A tasks worker --loglevel=info aber als eine bekannte Tatsache, dass wir brauchen, um es

celery celery-task django supervisor supervisord

Luftstrom - Python-Datei NICHT in der gleichen DAG-Ordner

4 Antworten

Ich versuche, mit Luftstrom, der die Ausführung einer einfachen Aufgabe python. from __future__ import print_function from airflow.operators.python_operator import PythonOperator from airflow.models import DAG from datetime import datetime, timedelta from pprint import pprint seven_days_ago = datetime.combine(datetime.today() - timedelta(7),

airflow celery celery-task python

Sellerie task-Status immer anhängig

3 Antworten

Ich bin ziemlich neu auf Sellerie und django im Allgemeinen, so bitte entschuldigen Sie meinen Mangel an wissen. Ich bin versucht zu laufen, ein test, um zu tun einige Berechnungen und warten, bis der test abgeschlossen, so

celery celery-task django django-celery python

Sellerie Arbeiter Fehler: ImportError kein Modul namens Sellerie

2 Antworten

Ich bin immer ein import error, wenn ich versuche zu starten, meine Sellerie-Arbeiter. Ich bin nicht sicher, was das Problem ist. Jegliche Hilfe würde sehr geschätzt werden. Mein Projekt: email/__init__.py /celery.py Ich versuche, führen Sie die Anwendung

celery celery-task flask python

Wie kann ich eine periodische Sellerie-Aufgabe manuell von der Shell ausführen?

2 Antworten

Ich bin mit Sellerie und django-celery. Ich habe eine regelmäßige Aufgabe, die ich gerne testen möchte. Ist es möglich, die periodische Abfrage aus der shell manuell, so dass ich die Ausgabe in der Konsole? InformationsquelleAutor der Frage

celery celery-task django django-celery python

Sellerie: Liste alle Aufgaben, geplant, aktiv * und * fertig

2 Antworten

Update für bounty Ich würde gerne eine Lösung, die nicht mit einem Monitor-thread, wenn möglich. Ich weiß, ich kann anzeigen geplanten und aktiv Aufgaben mit der Inspect Klasse meiner apps Control. i = myapp.control.inspect() currently_running = i.active()

celery celery-task

Löschen aller ausstehenden Aufgaben in Sellerie / Rabbitmq

7 Antworten

Wie lösche ich alle anstehenden Aufgaben, ohne zu wissen, die task_id für jede Aufgabe? InformationsquelleAutor der Frage nabizan | 2011-08-22

celery celery-task rabbitmq task

Importfehler in Sellerie

3 Antworten

dies ist der code, welchen ich verwende: from __future__ import absolute_import from celery import Celery celery1 = Celery('celery',broker='amqp://',backend='amqp://',include=['tasks']) celery1.conf.update( CELERY_TASK_RESULT_EXPIRES=3600, ) if __name__ == '__main__': celery1.start() wenn ich führen Sie den obigen code, es gibt mir die

celery celery-task pycharm python