Spaces:
Paused
Paused
Update app_celery.py
Browse files- app_celery.py +4 -1
app_celery.py
CHANGED
@@ -539,11 +539,14 @@ def generate_video():
|
|
539 |
@app.route("/stream", methods=['GET'])
|
540 |
def stream_video_chunks():
|
541 |
global chunk_tasks
|
542 |
-
|
|
|
|
|
543 |
@stream_with_context
|
544 |
def generate_chunks():
|
545 |
video_chunk_paths = []
|
546 |
for index, task in enumerate(chunk_tasks):
|
|
|
547 |
try:
|
548 |
video_chunk_path = task.get() # Wait for each task to complete
|
549 |
video_chunk_paths.append(video_chunk_path)
|
|
|
539 |
@app.route("/stream", methods=['GET'])
|
540 |
def stream_video_chunks():
|
541 |
global chunk_tasks
|
542 |
+
print("chunk_tasks:",chunk_tasks)
|
543 |
+
for index, task in enumerate(chunk_tasks):
|
544 |
+
print("task:",task)
|
545 |
@stream_with_context
|
546 |
def generate_chunks():
|
547 |
video_chunk_paths = []
|
548 |
for index, task in enumerate(chunk_tasks):
|
549 |
+
print("task:",task)
|
550 |
try:
|
551 |
video_chunk_path = task.get() # Wait for each task to complete
|
552 |
video_chunk_paths.append(video_chunk_path)
|