Merge branch 'main' of https://huggingface.co/spaces/Yakova/Rectifier

App/Worker.py

@@ -189,30 +189,21 @@ async def cleanup_temp_directory(
     chat_id: int = -1002069945904,
 ):
     video_folder_dir = f"/tmp/Video/{video_task.constants.task}"
+    
     try:
-        if not SERVER_STATE.MASTER:
-            await upload_file(
-                output_dir,
-                SERVER_STATE.SPACE_HOST,
-                video_task.constants.chunk,
-                video_task.constants.task,
-            )
-        else:
+        print("sending...")
+        # bot.send_video(chat_id=chat_id,caption="Your Video Caption",file_name=output_dir)
+        await bot.send_file(chat_id, file=output_dir, caption="Your video caption")
+
 
-            os.makedirs(video_folder_dir, exist_ok=True)
-            shutil.move(
-                output_dir, f"{video_folder_dir}/{video_task.constants.chunk}.mp4"
-            )
 
-    except Exception as e:
-        print(e)
     finally:
-        remotion_app_dir = os.path.join("/srv", "Remotion-app")
-        shutil.rmtree(remotion_app_dir)
+        #remotion_app_dir = os.path.join("/srv", "Remotion-app")
+        #shutil.rmtree(remotion_app_dir)
         # use the cache
-        shutil.copytree(temp_dir, remotion_app_dir)
-        if not SERVER_STATE.CACHED:
-            SERVER_STATE.CACHED = True
+        #shutil.copytree(temp_dir, remotion_app_dir)
+        #if not SERVER_STATE.CACHED:
+        #    SERVER_STATE.CACHED = True
         # Cleanup: Remove the temporary directory
         shutil.rmtree(temp_dir, ignore_errors=True)
 
@@ -235,7 +226,7 @@ async def celery_task(video_task: EditorRequest):
     create_json_file(video_task.assets, assets_dir)
     download_assets(video_task.links, temp_dir)
     render_video(temp_dir, output_dir)
-    unsilence(temp_dir)
+    #unsilence(temp_dir)
     await cleanup_temp_directory(temp_dir, output_dir, video_task)
 
     # chain(

App/app.py

@@ -10,11 +10,12 @@ manager = WorkerClient()
 
 @app.on_event("startup")
 async def startup_event():
-    if SERVER_STATE.MASTER:
-        await bot.start()
-    response = await manager.register_worker()
-    if not response:
-        print("Error registering worker")
+    await bot.start()
+    #if SERVER_STATE.MASTER:
+
+    #response = await manager.register_worker()
+    #if not response:
+    #    print("Error registering worker")
 
 
 @app.get("/")

Dockerfile

@@ -62,7 +62,7 @@ COPY --chown=admin . /srv
 # Command to run the application
 # CMD python -m uvicorn App.app:app --host 0.0.0.0 --port 7860 &  python -m celery -A App.Worker.celery worker -c 5  --max-tasks-per-child=1  --without-heartbeat 
 
-CMD python -m uvicorn App.app:app --host 0.0.0.0 --port 7860 
+CMD python -m uvicorn App.app:app --workers 4 --host 0.0.0.0 --port 7860 
 
 # Expose port
 EXPOSE 7860

Remotion-app/remotion.config.js

@@ -10,6 +10,6 @@ Config.overrideWebpackConfig((currentConfiguration) => {
 	return enableTailwind(currentConfiguration);
 });
 
-Config.setC;
+//Config.setBrowserExecutable("/usr/bin/chrome-headless-shell");
 Config.setVideoImageFormat('jpeg');
 Config.setConcurrency(1);

Remotion-app/src/HelloWorld/index.jsx

@@ -10,8 +10,9 @@ const HelloWorld = React.memo(() => {
 	return (
 		<AbsoluteFill style={{position: 'relative', backgroundColor: 'black'}}>
 			<BackgroundStream />
-			<ImageStream />
-			<TextStream />
+ <ImageStream /> 
+			
+					<TextStream /> 
 			<VideoStream />
 			<AudioStream />
 		</AbsoluteFill>