Sellerie - call-Funktion auf die Aufgabe

Ich bin mit Sellerie mit django und rabbitmq zum erstellen einer message queue. Ich habe auch ein Arbeiter, der ursprünglich aus einer anderen Maschine. In einem django, das ich beginne einem Prozess wie diesem:

def processtask(request, name):
  args = ["ls", "-l"]
  MyTask.delay(args)
  return HttpResponse("Task set to execute.")

Meine Aufgabe ist so konfiguriert:

class MyTask(Task):
  def run(self, args):
    p = subprocess.Popen(args, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
    (out, err) = p.communicate()
    return out

Meine Frage ist nun, wie kann ein broker (meine django-Projekt) erhalten nun die Ausgabe von "ls -l" - Befehl, der den Arbeitnehmer ausgeführt, auf seinem computer. Ich denke die beste Sache wäre, für die Arbeiter, eine Funktion aufzurufen broker wenn Sie bereit zum senden der Ausgabe vom ausgeführten Befehl.

Ich würde gerne die Ausgabe vom Arbeiter asynchron, dann aktualisieren Sie die Webseite mit dem Ausgang, aber das ein anderes mal. Für jetzt würde ich nur gerne die Ausgabe vom Arbeiter.

Update

Jetzt habe ich eine HTTP-GET-request ausgelöst wird, die am Ende der Aufgabe, Benachrichtigung von der web-Anwendung, die Aufgabe ist getan - ich bin auch der Versand der task_id in der http-GET. Die http-Methode GET ruft django Ansicht, die erstellt AsyncResult und bekommt das Ergebnis, aber das problem ist, dass beim Aufruf Ergebnis.get() bekomme ich die folgende Fehlermeldung:

/usr/lib64/python2.6/site-packages/django_celery-2.5.1-py2.6.egg/djcelery/managers.py:178: TxIsolationWarning: Polling results with transaction isolation level repeatable-read within the same transaction may give outdated results. Be sure to commit the transaction for each poll iteration.
  "Polling results with transaction isolation level"

Irgendwelche Ideen, warum? Ich bin nicht mit der Datenbank, denn ich bin mit rabbitmq mit AMQP.

Update.

Ich würde sehr gerne verwenden Dritte option, das scheint die beste option - für kleine und große Werte zurückgeben. Meine ganze Aufgabe sieht wie folgt aus:

class MyTask(Task):
  def __call__(self, *args, **kwargs):
    return self.run(*args, **kwargs)

  def after_return(self, status, retval, task_id, args, kwargs, einfo):
    if self.webhost is not None:
      conn = httplib.HTTPConnection(self.webhost, self.webport)
      conn.request("HEAD", "/vuln/task/output/"+task_id)

  def run(self, args, webhost=None, webport=None):
    self.webhost = webhost
    self.webport = webport
    r = "This is a basic result string used for code clarity"
    return r

So, ich habe überschrieben, die after_return-Funktion, die sollte auch die Sperre auf meine Aufgabe, da die Aufgabe der Funktion run() bereits einen Wert zurückgegeben. In den HEAD-request, ich bin grundsätzlich Aufruf einer django-Funktion, die Anrufe AsyncResult auf task_id, die sollten mit dem Ergebnis der Aufgabe. Ich habe willkürliche Ergebnis für Testzwecke in meinem Fall, da es nur zum testen.

Ich würde gerne wissen, warum der obige code funktioniert nicht. Ich kann verwenden on_success, aber ich glaube nicht, dass es einen Unterschied machen wird - oder wird es?