29 lines
731 B
Python
29 lines
731 B
Python
from app.core._utils.send_status import send_status
|
|
|
|
from app.core.logger import make_log
|
|
from app.core.storage import db_session
|
|
import asyncio
|
|
|
|
|
|
async def main():
|
|
make_log("Uploader", "Service started", level="info")
|
|
seqno = 0
|
|
while True:
|
|
# make_log("Uploader", "Service running", level="debug")
|
|
# with db_session() as session:
|
|
# for stored_content in session.query(StoredContent).filter(StoredContent.uploaded == False).all():
|
|
# pass
|
|
|
|
await asyncio.sleep(5)
|
|
await send_status("uploader", f"working (seqno={seqno})")
|
|
seqno += 1
|
|
|
|
if __name__ == '__main__':
|
|
loop = asyncio.get_event_loop()
|
|
loop.run_until_complete(main())
|
|
loop.close()
|
|
|
|
|
|
|
|
|