Spanicin commited on
Commit
bf58d82
·
verified ·
1 Parent(s): e4f7513

Update app_celery.py

Browse files
Files changed (1) hide show
  1. app_celery.py +4 -1
app_celery.py CHANGED
@@ -30,6 +30,9 @@ from celery import Celery
30
  # from gevent import monkey
31
  # monkey.patch_all()
32
 
 
 
 
33
 
34
 
35
  class AnimationConfig:
@@ -387,7 +390,7 @@ def split_audio(audio_path, chunk_duration=5):
387
 
388
  return audio_chunks
389
 
390
- @celery.task
391
  def process_video_for_chunk(audio_chunk_path, args_dict, chunk_index):
392
  print("Entered process_video_for_chunk")
393
  args = AnimationConfig(
 
30
  # from gevent import monkey
31
  # monkey.patch_all()
32
 
33
+ import multiprocessing
34
+ multiprocessing.set_start_method('spawn', force=True)
35
+
36
 
37
 
38
  class AnimationConfig:
 
390
 
391
  return audio_chunks
392
 
393
+ @celery.task(bind=True)
394
  def process_video_for_chunk(audio_chunk_path, args_dict, chunk_index):
395
  print("Entered process_video_for_chunk")
396
  args = AnimationConfig(