workflow celery

Ammarmoulla · Oct 11, 2023 · ffec31b · ffec31b
1 parent 68f69b7
commit ffec31b
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 4 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -16,7 +16,7 @@ services:
     expose:
       - '8000'
     volumes:
-      - .env:.env
+      - .env:/video_text/.env
     entrypoint: ./scripts/server-entrypoint.sh
     depends_on:
       - redis

diff --git a/video/helper.py b/video/helper.py
@@ -13,4 +13,6 @@ def encode_image(frame):
     return base64.b64encode(frame).decode("utf-8")
 
 def decode_image(frame):
-    return base64.decodebytes(frame.encode())
+    return base64.decodebytes(frame.encode())
+
+
diff --git a/video/tasks.py b/video/tasks.py
@@ -30,9 +30,15 @@ def process_clip(clip, text, x, y, fontsize):
 
     processed_frames = []
 
-    # g = group(
+    # job = group([
+    #     process_frame.s(frame, text, x, y, fontsize)
+    # ])
 
-    # )
+    # result = job.apply_async()
+
+    # result.ready()  # have all subtasks completed?
+
+    # result.successful()
     for frame in clip.iter_frames():
         processed_frame = process_frame.delay(frame, text, x, y, fontsize).get()
         processed_frames.append(processed_frame)

diff --git a/video_editors/2023-10-11-0834201540520000/video_1.mp4 b/video_editors/2023-10-11-0834201540520000/video_1.mp4
diff --git a/video_editors/2023-10-11-0834201540520000/video_1_edit.mp4 b/video_editors/2023-10-11-0834201540520000/video_1_edit.mp4