<NME> tasks.py
<BEF> from celery.task import task
from models import VideoVersion


@task
def encodevideo(source, size, codec):
    version, created = VideoVersion.objects.get_or_create(source = source, size = size, codec = codec)
    version.encode()
    return

<MSG> various tweaks for the queue

<DFF> @@ -4,6 +4,11 @@ from models import VideoVersion
 
 @task
 def encodevideo(source, size, codec):
+    logger =  encodevideo.get_logger()
+    logger.info("**********************")
+    print "======== in encodevideo task ========="
     version, created = VideoVersion.objects.get_or_create(source = source, size = size, codec = codec)
-    version.encode()
-    return
\ No newline at end of file
+    print "== version, created", version, created
+    version_status = version.encode()
+    print "== version_status", version_status
+    return version_status
\ No newline at end of file

{'addition_count': 7, 'commit_subject': 'various tweaks for the queue', 'deletion_count': 2, 'file_extension': '.py', 'lang': 'py', 'license': 'bsd-2-clause', 'repo_name': 'evildmp/Arkestra'}