2023-08-04 16:40:49.759 | ERROR    | src.bot_tools.decorators:_:35 -
Traceback (most recent call last):

  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/backends/utils.py", line 89, in _execute
    return self.cursor.execute(sql, params)
           │    │      │       │    └ (Int8(123131321),)
           │    │      │       └ 'SELECT "src_user"."tgid", "src_user"."min_profit", "src_user"."min_usd_size", "src_user"."min_profit_growth", "src_user"."on...
           │    │      └ <function Cursor.execute at 0x107bf8a60>
           │    └ <django.db.backends.postgresql.base.Cursor [closed] [ACTIVE] (host=123.123.123.123 user=123123123 database=123123) at 0x11ec...
           └ <django.db.backends.utils.CursorWrapper object at 0x11ef97fd0>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/psycopg/cursor.py", line 723, in execute
    raise ex.with_traceback(None)

psycopg.OperationalError: consuming input failed: Operation timed out


The above exception was the direct cause of the following exception:


Traceback (most recent call last):

  File "/opt/homebrew/Cellar/python@3.10/3.10.12_1/Frameworks/Python.framework/Versions/3.10/lib/python3.10/runpy.py", line 196, in _run_module_as_main
    return _run_code(code, main_globals, None,
           │         │     └ {'__name__': '__main__', '__doc__': None, '__package__': 'src.signals_bot', '__loader__': <_frozen_importlib_external.SourceF...
           │         └ <code object <module> at 0x104cd6ad0, file "/Users/lifr0m/code/arbitrage/src/signals_bot/main.py", line 1>
           └ <function _run_code at 0x104ad79a0>

  File "/opt/homebrew/Cellar/python@3.10/3.10.12_1/Frameworks/Python.framework/Versions/3.10/lib/python3.10/runpy.py", line 86, in _run_code
    exec(code, run_globals)
         │     └ {'__name__': '__main__', '__doc__': None, '__package__': 'src.signals_bot', '__loader__': <_frozen_importlib_external.SourceF...
         └ <code object <module> at 0x104cd6ad0, file "/Users/lifr0m/code/arbitrage/src/signals_bot/main.py", line 1>

  File "/Users/lifr0m/code/arbitrage/src/signals_bot/main.py", line 44, in <module>
    loop.run_until_complete(
    │    └ <method 'run_until_complete' of 'uvloop.loop.Loop' objects>
    └ <uvloop.Loop running=True closed=False debug=False>

  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/telethon/client/updates.py", line 543, in _dispatch_update
    await callback(event)
          │        └ <telethon.events.newmessage.NewMessage.Event object at 0x11ef96980>
          └ <function _ at 0x11ef851b0>

> File "/Users/lifr0m/code/arbitrage/src/bot_tools/decorators.py", line 33, in _
    await func(event)
          │    └ <telethon.events.newmessage.NewMessage.Event object at 0x11ef96980>
          └ <function _ at 0x11ef85090>

  File "/Users/lifr0m/code/arbitrage/src/signals_bot/handlers.py", line 28, in _
    user = await db.get_user(event.sender_id)
                 │  │        └ <telethon.events.newmessage.NewMessage.Event object at 0x11ef96980>
                 │  └ <function get_user at 0x11ef84e50>
                 └ <module 'src.signals_bot.db' from '/Users/lifr0m/code/arbitrage/src/signals_bot/db.py'>

  File "/Users/lifr0m/code/arbitrage/src/signals_bot/db.py", line 7, in get_user
    return await User.objects.aget(tgid=tgid)
                 │    │                 └ 123123123
                 │    └ <django.db.models.manager.ManagerDescriptor object at 0x1188c5cc0>
                 └ <class 'src.models.User'>

  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/models/query.py", line 649, in aget
    return await sync_to_async(self.get)(*args, **kwargs)
                 │             │    │     │       └ {'tgid': 123123123}
                 │             │    │     └ ()
                 │             │    └ <function QuerySet.get at 0x1076ad360>
                 │             └ <unprintable QuerySet object>
                 └ <function sync_to_async at 0x106f656c0>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/asgiref/sync.py", line 479, in __call__
    ret: _R = await loop.run_in_executor(
                    │    └ <method 'run_in_executor' of 'uvloop.loop.Loop' objects>
                    └ <uvloop.Loop running=True closed=False debug=False>

  File "/opt/homebrew/Cellar/python@3.10/3.10.12_1/Frameworks/Python.framework/Versions/3.10/lib/python3.10/concurrent/futures/thread.py", line 58, in run
    result = self.fn(*self.args, **self.kwargs)
             │        │            └ None
             │        └ None
             └ None

  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/asgiref/sync.py", line 538, in thread_handler
    return func(*args, **kwargs)
           │     │       └ {}
           │     └ <unprintable tuple object>
           └ <built-in method run of _contextvars.Context object at 0x11e7be540>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/models/query.py", line 633, in get
    num = len(clone)
              └ <unprintable QuerySet object>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/models/query.py", line 380, in __len__
    self._fetch_all()
    │    └ <function QuerySet._fetch_all at 0x1076afd90>
    └ <unprintable QuerySet object>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/models/query.py", line 1881, in _fetch_all
    self._result_cache = list(self._iterable_class(self))
    │    │                    │    │               └ <unprintable QuerySet object>
    │    │                    │    └ <class 'django.db.models.query.ModelIterable'>
    │    │                    └ <unprintable QuerySet object>
    │    └ None
    └ <unprintable QuerySet object>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/models/query.py", line 91, in __iter__
    results = compiler.execute_sql(
              │        └ <function SQLCompiler.execute_sql at 0x11ef87be0>
              └ <SQLCompiler model=User connection=<DatabaseWrapper vendor='postgresql' alias='default'> using='default'>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/models/sql/compiler.py", line 1562, in execute_sql
    cursor.execute(sql, params)
    │      │       │    └ (Int8(123123123),)
    │      │       └ 'SELECT "src_user"."tgid", "src_user"."min_profit", "src_user"."min_usd_size", "src_user"."min_profit_growth", "src_user"."on...
    │      └ <function CursorWrapper.execute at 0x1074d6dd0>
    └ <django.db.backends.utils.CursorWrapper object at 0x11ef97fd0>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/backends/utils.py", line 67, in execute
    return self._execute_with_wrappers(
           │    └ <function CursorWrapper._execute_with_wrappers at 0x1074d6ef0>
           └ <django.db.backends.utils.CursorWrapper object at 0x11ef97fd0>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/backends/utils.py", line 80, in _execute_with_wrappers
    return executor(sql, params, many, context)
           │        │    │       │     └ {'connection': <DatabaseWrapper vendor='postgresql' alias='default'>, 'cursor': <django.db.backends.utils.CursorWrapper objec...
           │        │    │       └ False
           │        │    └ (Int8(123123123),)
           │        └ 'SELECT "src_user"."tgid", "src_user"."min_profit", "src_user"."min_usd_size", "src_user"."min_profit_growth", "src_user"."on...
           └ <bound method CursorWrapper._execute of <django.db.backends.utils.CursorWrapper object at 0x11ef97fd0>>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/backends/utils.py", line 84, in _execute
    with self.db.wrap_database_errors:
         │    │  └ <django.db.utils.DatabaseErrorWrapper object at 0x11ef94460>
         │    └ <DatabaseWrapper vendor='postgresql' alias='default'>
         └ <django.db.backends.utils.CursorWrapper object at 0x11ef97fd0>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/utils.py", line 91, in __exit__
    raise dj_exc_value.with_traceback(traceback) from exc_value
          │            │              │               └ OperationalError('consuming input failed: Operation timed out')
          │            │              └ <traceback object at 0x11effd140>
          │            └ <method 'with_traceback' of 'BaseException' objects>
          └ OperationalError('consuming input failed: Operation timed out')
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/django/db/backends/utils.py", line 89, in _execute
    return self.cursor.execute(sql, params)
           │    │      │       │    └ (Int8(123123123),)
           │    │      │       └ 'SELECT "src_user"."tgid", "src_user"."min_profit", "src_user"."min_usd_size", "src_user"."min_profit_growth", "src_user"."on...
           │    │      └ <function Cursor.execute at 0x107bf8a60>
           │    └ <django.db.backends.postgresql.base.Cursor [closed] [ACTIVE] (host=123.123.123.123 user=12312123 database=123123123) at 0x11ec...
           └ <django.db.backends.utils.CursorWrapper object at 0x11ef97fd0>
  File "/Users/lifr0m/code/arbitrage/venv/lib/python3.10/site-packages/psycopg/cursor.py", line 723, in execute
    raise ex.with_traceback(None)

django.db.utils.OperationalError: consuming input failed: Operation timed out