Advertisement
Guest User

PyMySQL Error with celery concurrency

a guest
Oct 23rd, 2020
651
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 16.19 KB | None | 0 0
  1. [2020-10-23 17:03:05,982: ERROR/ForkPoolWorker-3] Task PyMatcha.utils.tasks.take_random_users_online[da82e150-e8bf-45f0-9330-93ecce584028] raised unexpected: InternalError('Packet sequence number wrong - got 114 expected 1')
  2. Traceback (most recent call last):
  3.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 409, in trace_task
  4.     R = retval = fun(*args, **kwargs)
  5.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 701, in __protected_call__
  6.     return self.run(*args, **kwargs)
  7.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/tasks.py", line 133, in take_random_users_online
  8.     for user in User.select_random(100):
  9.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/orm/_model.py", line 380, in select_random
  10.     c.execute(
  11.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 163, in execute
  12.     result = self._query(query)
  13.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 321, in _query
  14.     conn.query(q)
  15.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 505, in query
  16.     self._affected_rows = self._read_query_result(unbuffered=unbuffered)
  17.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 724, in _read_query_result
  18.     result.read()
  19.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 1069, in read
  20.     first_packet = self.connection._read_packet()
  21.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 658, in _read_packet
  22.     raise err.InternalError(
  23. pymysql.err.InternalError: Packet sequence number wrong - got 114 expected 1
  24. [2020-10-23 17:03:05,982: ERROR/ForkPoolWorker-2] Task PyMatcha.utils.tasks.take_random_users_online[b4bebdba-f5a0-49fb-af6c-250bb504d1bf] raised unexpected: AssertionError('Result length not requested length:\nExpected=118.  Actual=115.  Position: 434.  Data Length: 549')
  25. Traceback (most recent call last):
  26.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 409, in trace_task
  27.     R = retval = fun(*args, **kwargs)
  28.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 701, in __protected_call__
  29.     return self.run(*args, **kwargs)
  30.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/tasks.py", line 133, in take_random_users_online
  31.     for user in User.select_random(100):
  32.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/orm/_model.py", line 380, in select_random
  33.     c.execute(
  34.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 163, in execute
  35.     result = self._query(query)
  36.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 321, in _query
  37.     conn.query(q)
  38.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 505, in query
  39.     self._affected_rows = self._read_query_result(unbuffered=unbuffered)
  40.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 724, in _read_query_result
  41.     result.read()
  42.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 1076, in read
  43.     self._read_result_packet(first_packet)
  44.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 1146, in _read_result_packet
  45.     self._read_rowdata_packet()
  46.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 1184, in _read_rowdata_packet
  47.     rows.append(self._read_row_from_packet(packet))
  48.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 1193, in _read_row_from_packet
  49.     data = packet.read_length_coded_string()
  50.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/protocol.py", line 178, in read_length_coded_string
  51.     return self.read(length)
  52.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/protocol.py", line 73, in read
  53.     raise AssertionError(error)
  54. AssertionError: Result length not requested length:
  55. Expected=118.  Actual=115.  Position: 434.  Data Length: 549
  56. [2020-10-23 17:03:05,993: ERROR/ForkPoolWorker-3] Task PyMatcha.utils.tasks.random_bot_action[0026dbef-c2e3-41d7-b4de-4e6101a2854a] raised unexpected: InterfaceError(0, '')
  57. Traceback (most recent call last):
  58.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 409, in trace_task
  59.     R = retval = fun(*args, **kwargs)
  60.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 701, in __protected_call__
  61.     return self.run(*args, **kwargs)
  62.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/tasks.py", line 145, in random_bot_action
  63.     for user in User.select_random(200):
  64.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/orm/_model.py", line 380, in select_random
  65.     c.execute(
  66.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 163, in execute
  67.     result = self._query(query)
  68.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 321, in _query
  69.     conn.query(q)
  70.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 504, in query
  71.     self._execute_command(COMMAND.COM_QUERY, sql)
  72.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 742, in _execute_command
  73.     raise err.InterfaceError(0, '')
  74. pymysql.err.InterfaceError: (0, '')
  75. [2020-10-23 17:03:05,998: INFO/MainProcess] Received task: PyMatcha.utils.tasks.random_bot_action[85785730-d3af-4cbc-a385-fc34ccbd3d4b]  
  76. [2020-10-23 17:03:06,000: ERROR/ForkPoolWorker-3] Task PyMatcha.utils.tasks.take_random_users_online[e7e3da39-4b41-48b2-b312-6cc018d901bd] raised unexpected: InterfaceError(0, '')
  77. Traceback (most recent call last):
  78.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 409, in trace_task
  79.     R = retval = fun(*args, **kwargs)
  80.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 701, in __protected_call__
  81.     return self.run(*args, **kwargs)
  82.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/tasks.py", line 133, in take_random_users_online
  83.     for user in User.select_random(100):
  84.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/orm/_model.py", line 380, in select_random
  85.     c.execute(
  86.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 163, in execute
  87.     result = self._query(query)
  88.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 321, in _query
  89.     conn.query(q)
  90.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 504, in query
  91.     self._execute_command(COMMAND.COM_QUERY, sql)
  92.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 742, in _execute_command
  93.     raise err.InterfaceError(0, '')
  94. pymysql.err.InterfaceError: (0, '')
  95. [2020-10-23 17:03:06,006: ERROR/ForkPoolWorker-3] Task PyMatcha.utils.tasks.random_bot_action[29b361eb-84ee-448a-a59e-82e0f0ac0615] raised unexpected: InterfaceError(0, '')
  96. Traceback (most recent call last):
  97.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 409, in trace_task
  98.     R = retval = fun(*args, **kwargs)
  99.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 701, in __protected_call__
  100.     return self.run(*args, **kwargs)
  101.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/tasks.py", line 145, in random_bot_action
  102.     for user in User.select_random(200):
  103.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/orm/_model.py", line 380, in select_random
  104.     c.execute(
  105.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 163, in execute
  106.     result = self._query(query)
  107.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 321, in _query
  108.     conn.query(q)
  109.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 504, in query
  110.     self._execute_command(COMMAND.COM_QUERY, sql)
  111.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 742, in _execute_command
  112.     raise err.InterfaceError(0, '')
  113. pymysql.err.InterfaceError: (0, '')
  114. [2020-10-23 17:03:06,012: ERROR/ForkPoolWorker-3] Task PyMatcha.utils.tasks.calc_search_min_max[84bfcc38-4922-4085-8de6-edfa3486379a] raised unexpected: InterfaceError(0, '')
  115. Traceback (most recent call last):
  116.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 409, in trace_task
  117.     R = retval = fun(*args, **kwargs)
  118.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 701, in __protected_call__
  119.     return self.run(*args, **kwargs)
  120.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/tasks.py", line 110, in calc_search_min_max
  121.     for user in User.select_all():
  122.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/orm/_model.py", line 369, in select_all
  123.     c.execute("""SELECT * FROM {}""".format(cls.table_name))
  124.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 163, in execute
  125.     result = self._query(query)
  126.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 321, in _query
  127.     conn.query(q)
  128.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 504, in query
  129.     self._execute_command(COMMAND.COM_QUERY, sql)
  130.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 742, in _execute_command
  131.     raise err.InterfaceError(0, '')
  132. pymysql.err.InterfaceError: (0, '')
  133. [2020-10-23 17:03:06,018: ERROR/ForkPoolWorker-3] Task PyMatcha.utils.tasks.take_users_offline[a1a80f0d-7648-4d95-93b5-ba95b27ca2c5] raised unexpected: InterfaceError(0, '')
  134. Traceback (most recent call last):
  135.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 409, in trace_task
  136.     R = retval = fun(*args, **kwargs)
  137.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 701, in __protected_call__
  138.     return self.run(*args, **kwargs)
  139.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/tasks.py", line 70, in take_users_offline
  140.     for user in User.get_multis(is_online=True):
  141.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/orm/_model.py", line 343, in get_multis
  142.     c.execute(
  143.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 163, in execute
  144.     result = self._query(query)
  145.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 321, in _query
  146.     conn.query(q)
  147.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 504, in query
  148.     self._execute_command(COMMAND.COM_QUERY, sql)
  149.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 742, in _execute_command
  150.     raise err.InterfaceError(0, '')
  151. pymysql.err.InterfaceError: (0, '')
  152. [2020-10-23 17:03:06,024: ERROR/ForkPoolWorker-3] Task PyMatcha.utils.tasks.reset_superlikes[8cd2fe51-4536-4159-881c-e1f783ef7685] raised unexpected: InterfaceError(0, '')
  153. Traceback (most recent call last):
  154.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 409, in trace_task
  155.     R = retval = fun(*args, **kwargs)
  156.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 701, in __protected_call__
  157.     return self.run(*args, **kwargs)
  158.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/tasks.py", line 95, in reset_superlikes
  159.     for user in User.select_all():
  160.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/orm/_model.py", line 369, in select_all
  161.     c.execute("""SELECT * FROM {}""".format(cls.table_name))
  162.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 163, in execute
  163.     result = self._query(query)
  164.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 321, in _query
  165.     conn.query(q)
  166.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 504, in query
  167.     self._execute_command(COMMAND.COM_QUERY, sql)
  168.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 742, in _execute_command
  169.     raise err.InterfaceError(0, '')
  170. pymysql.err.InterfaceError: (0, '')
  171. [2020-10-23 17:03:06,030: ERROR/ForkPoolWorker-3] Task PyMatcha.utils.tasks.take_random_users_online[f3534903-35ea-4762-bfe4-a8e763b99f43] raised unexpected: InterfaceError(0, '')
  172. Traceback (most recent call last):
  173.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 409, in trace_task
  174.     R = retval = fun(*args, **kwargs)
  175.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 701, in __protected_call__
  176.     return self.run(*args, **kwargs)
  177.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/tasks.py", line 133, in take_random_users_online
  178.     for user in User.select_random(100):
  179.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/orm/_model.py", line 380, in select_random
  180.     c.execute(
  181.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 163, in execute
  182.     result = self._query(query)
  183.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 321, in _query
  184.     conn.query(q)
  185.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 504, in query
  186.     self._execute_command(COMMAND.COM_QUERY, sql)
  187.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 742, in _execute_command
  188.     raise err.InterfaceError(0, '')
  189. pymysql.err.InterfaceError: (0, '')
  190. [2020-10-23 17:03:06,037: ERROR/ForkPoolWorker-3] Task PyMatcha.utils.tasks.random_bot_action[85785730-d3af-4cbc-a385-fc34ccbd3d4b] raised unexpected: InterfaceError(0, '')
  191. Traceback (most recent call last):
  192.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 409, in trace_task
  193.     R = retval = fun(*args, **kwargs)
  194.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/celery/app/trace.py", line 701, in __protected_call__
  195.     return self.run(*args, **kwargs)
  196.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/tasks.py", line 145, in random_bot_action
  197.     for user in User.select_random(200):
  198.   File "/Users/seluj78/Projects/PyMatcha/backend/PyMatcha/utils/orm/_model.py", line 380, in select_random
  199.     c.execute(
  200.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 163, in execute
  201.     result = self._query(query)
  202.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/cursors.py", line 321, in _query
  203.     conn.query(q)
  204.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 504, in query
  205.     self._execute_command(COMMAND.COM_QUERY, sql)
  206.   File "/Users/seluj78/Projects/PyMatcha/venv/lib/python3.8/site-packages/pymysql/connections.py", line 742, in _execute_command
  207.     raise err.InterfaceError(0, '')
  208. pymysql.err.InterfaceError: (0, '')
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement