Update backend/main.py
Browse files- backend/main.py +12 -11
backend/main.py
CHANGED
|
@@ -1,34 +1,35 @@
|
|
|
|
|
|
|
|
| 1 |
from fastapi import FastAPI, UploadFile, File, Form, Header, BackgroundTasks
|
| 2 |
from fastapi.responses import JSONResponse
|
| 3 |
from pydantic import BaseModel
|
| 4 |
from typing import Optional, List
|
| 5 |
-
from
|
| 6 |
from worker import run_job
|
| 7 |
import db
|
| 8 |
|
| 9 |
app = FastAPI()
|
| 10 |
queue = JobQueue()
|
| 11 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 12 |
class MergeRequest(BaseModel):
|
| 13 |
-
model_a_source: str
|
| 14 |
model_a_id: str
|
| 15 |
model_b_source: str
|
| 16 |
model_b_id: str
|
| 17 |
-
method: str = "linear"
|
| 18 |
-
merge_type: Optional[str] = "linear"
|
| 19 |
linear_alpha: Optional[float] = 0.5
|
| 20 |
evo_params: Optional[dict] = None
|
| 21 |
dataset: Optional[str] = None
|
| 22 |
output_repo_name: Optional[str] = None
|
| 23 |
hf_token_manual: Optional[str] = None
|
| 24 |
civitai_key: Optional[str] = None
|
| 25 |
-
franken_layers: Optional[List[str]] = None
|
| 26 |
-
|
| 27 |
-
@app.on_event("startup")
|
| 28 |
-
async def startup():
|
| 29 |
-
await db.init_db()
|
| 30 |
-
import asyncio
|
| 31 |
-
asyncio.create_task(queue.process_jobs())
|
| 32 |
|
| 33 |
@app.post("/api/submit-job")
|
| 34 |
async def submit_job(
|
|
|
|
| 1 |
+
import os
|
| 2 |
+
import asyncio
|
| 3 |
from fastapi import FastAPI, UploadFile, File, Form, Header, BackgroundTasks
|
| 4 |
from fastapi.responses import JSONResponse
|
| 5 |
from pydantic import BaseModel
|
| 6 |
from typing import Optional, List
|
| 7 |
+
from job_queue import JobQueue
|
| 8 |
from worker import run_job
|
| 9 |
import db
|
| 10 |
|
| 11 |
app = FastAPI()
|
| 12 |
queue = JobQueue()
|
| 13 |
|
| 14 |
+
@app.on_event("startup")
|
| 15 |
+
async def startup():
|
| 16 |
+
await db.init_db()
|
| 17 |
+
asyncio.create_task(queue.process_jobs())
|
| 18 |
+
|
| 19 |
class MergeRequest(BaseModel):
|
| 20 |
+
model_a_source: str
|
| 21 |
model_a_id: str
|
| 22 |
model_b_source: str
|
| 23 |
model_b_id: str
|
| 24 |
+
method: str = "linear"
|
| 25 |
+
merge_type: Optional[str] = "linear"
|
| 26 |
linear_alpha: Optional[float] = 0.5
|
| 27 |
evo_params: Optional[dict] = None
|
| 28 |
dataset: Optional[str] = None
|
| 29 |
output_repo_name: Optional[str] = None
|
| 30 |
hf_token_manual: Optional[str] = None
|
| 31 |
civitai_key: Optional[str] = None
|
| 32 |
+
franken_layers: Optional[List[str]] = None
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 33 |
|
| 34 |
@app.post("/api/submit-job")
|
| 35 |
async def submit_job(
|