Update handler.py

handler.py

@@ -6,55 +6,7 @@ from diffusers import FluxPipeline
 from huggingface_inference_toolkit.logging import logger
 from para_attn.first_block_cache.diffusers_adapters import apply_cache_on_pipe
 import time
-import uuid
-from huggingface_hub import HfApi
 
-from pyngrok import ngrok
-import subprocess
-from fastapi import FastAPI
-from fastapi.responses import FileResponse
-import uvicorn
-import threading
-
-image_directory='./images'
-if not os.path.exists(image_directory):
-    os.makedirs(image_directory)
-
-app = FastAPI()
-
-@app.get("/images/{image_name}")
-async def get_image(image_name: str):
-    image_path = os.path.join(image_directory, image_name)
-    
-    if os.path.exists(image_path):
-        return FileResponse(image_path)
-    else:
-        return {"error": "Image not found"}
-
-def run_uvicorn():
-    uvicorn.run(app, host="127.0.0.1", port=6000)
-
-uvicorn_thread = threading.Thread(target=run_uvicorn)
-uvicorn_thread.daemon = True  
-uvicorn_thread.start()
-
-authtoken = "2cvqFKWc1eb9b0aN7pRLDUBfEtC_2FUehxFL8CAKXRkW3Hfjo"
-commands = [
-    # "snap install ngrok",
-    f"ngrok config add-authtoken {authtoken}"
-]
-for command in commands:
-    try:
-        subprocess.run(command, shell=True, check=True)
-        logger.info(f"SUCCESS CMD: {command}")
-    except subprocess.CalledProcessError as e:
-        logger.info(f"Failed CMD: {e}")
-def run_ngrok():
-    subprocess.run(["ngrok", "http", "6000"])
-ngrok_thread = threading.Thread(target=run_ngrok)
-ngrok_thread.daemon = True 
-ngrok_thread.start()
-logger.info("ngrok is running in the background")
 
 class EndpointHandler:
     def __init__(self, path=""):
@@ -69,13 +21,7 @@ class EndpointHandler:
         self.pipe.vae = torch.compile(
             self.pipe.vae, mode="max-autotune-no-cudagraphs",
         )
-        # ngrok
-        self.public_url = ngrok.connect(6000).public_url
-        # subprocess.Popen(['ngrok', 'http', '6000'], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-        
-        logger.info("Ngrok is running in the background.")
 
-        
     def __call__(self, data: Dict[str, Any]) -> str:
         logger.info(f"Received incoming request with {data=}")
 
@@ -111,10 +57,4 @@ class EndpointHandler:
         end_time = time.time()
         time_taken = end_time - start_time
         print(f"Time taken: {time_taken:.2f} seconds")
-        filename = f"{uuid.uuid4()}.png"
-        image_path = f"/images/{filename}"
-
-        result.save(image_path)
-        image_url = f"{self.public_url+image_path}"
-
-        return image_url
+        return result