my-dev
/
uploader-bot
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

dev@locazia: add try-except

This commit is contained in:
user 2024-03-03 14:21:41 +03:00
parent 8fdd67dda1
commit b6a9b5c0ab
2 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/core/background/ton_service.py
View File

@ -55,7 +55,7 @@ async def main():
while True: while True:
sw_seqno_value = await get_sw_seqno() sw_seqno_value = await get_sw_seqno()
make_log("TON", "Service running (seqno}", level="debug") make_log("TON", f"Service running (seqno}", level="debug")
# with db_session() as session: # with db_session() as session:
# for stored_content in session.query(StoredContent).filter(StoredContent.uploaded == False).all(): # for stored_content in session.query(StoredContent).filter(StoredContent.uploaded == False).all():
# pass # pass

12
app/core/background/uploader_service.py
View File

@ -2,14 +2,21 @@ from app.core._utils.send_status import send_status
from app.core.logger import make_log from app.core.logger import make_log
from app.core.storage import db_session from app.core.storage import db_session
import traceback
import asyncio import asyncio
async def uploader_loop():
pass
async def main(): async def main():
make_log("Uploader", "Service started", level="info") make_log("Uploader", "Service started", level="info")
seqno = 0 seqno = 0
while True: while True:
# make_log("Uploader", "Service running", level="debug") try:
make_log("Uploader", "Service running", level="debug")
await uploader_loop()
# with db_session() as session: # with db_session() as session:
# for stored_content in session.query(StoredContent).filter(StoredContent.uploaded == False).all(): # for stored_content in session.query(StoredContent).filter(StoredContent.uploaded == False).all():
# pass # pass
@ -17,6 +24,9 @@ async def main():
await asyncio.sleep(5) await asyncio.sleep(5)
await send_status("uploader", f"working (seqno={seqno})") await send_status("uploader", f"working (seqno={seqno})")
seqno += 1 seqno += 1
except BaseException as e:
make_log("Uploader", f"Error: {e}" + '\n' + str(traceback.format_exc()), level="error")
await asyncio.sleep(3)
if __name__ == '__main__': if __name__ == '__main__':
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()