Compare commits
3 Commits
a3e3e568b4
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
| df2f8eaed1 | |||
| 2d026d8b16 | |||
| 4cb66ba293 |
@@ -5,7 +5,7 @@ from app.routers import acquire
|
|||||||
from app.routers import release
|
from app.routers import release
|
||||||
|
|
||||||
from app.storage import mongo
|
from app.storage import mongo
|
||||||
from daemons import base
|
from app.daemons import base
|
||||||
|
|
||||||
|
|
||||||
class Daemon(base.Daemon):
|
class Daemon(base.Daemon):
|
||||||
|
|||||||
@@ -1,14 +1,11 @@
|
|||||||
import datetime
|
|
||||||
import fastapi
|
import fastapi
|
||||||
import pydantic
|
import pydantic
|
||||||
|
|
||||||
from app.storage.mongo import locks
|
from app.storage.mongo import locks
|
||||||
from app.utils import time
|
|
||||||
|
|
||||||
|
|
||||||
class RequestBody(pydantic.BaseModel):
|
class RequestBody(pydantic.BaseModel):
|
||||||
name: str
|
name: str
|
||||||
ttl: int
|
|
||||||
|
|
||||||
|
|
||||||
router = fastapi.APIRouter()
|
router = fastapi.APIRouter()
|
||||||
|
|||||||
@@ -18,9 +18,3 @@ def create_indexes():
|
|||||||
database.get_collection('locks').create_index([
|
database.get_collection('locks').create_index([
|
||||||
('name', 1),
|
('name', 1),
|
||||||
], unique=True)
|
], unique=True)
|
||||||
|
|
||||||
|
|
||||||
def remove_outdated():
|
|
||||||
client = pymongo.MongoClient(CONNECTION_STRING)
|
|
||||||
while True:
|
|
||||||
|
|
||||||
Reference in New Issue
Block a user