Code

Batched kombu consumer#483

Code

Open

gfmio wants to merge 69 commits intoreddit:developreddit/baseplate.py:developfrom gfmio:batched-kombu-consumergfmio/baseplate.py:batched-kombu-consumerCopy head branch name to clipboard

+640-10

Commits

Commits on Aug 25, 2020

• add scheduler

  gfmio

  committed
  5d10ea7

• add ThreadedScheduler

  gfmio

  committed
  ba218ca

• add Timer

  gfmio

  committed
  294a22a

• refactor QueueConsumer and QueueConsumerFactory to support custom consumer implementations

  gfmio

  committed
  f8bb2d6

• add KombuBatchMessageHandler and KombuBatchQueueConsumer

  gfmio

  committed
  1b05dbc

• add .mypy_cache to .gitignore

  gfmio

  committed
  2b4b43c

• make fmt

  gfmio

  committed
  9be1d60

• fix types

  gfmio

  committed
  75c756a

• make fmt

  gfmio

  committed
  3b54d35

• lint

  gfmio

  committed
  b2c06fd

• lint

  gfmio

  committed
  3e321b0

Commits on Aug 29, 2020

• address PR comments

  gfmio

  committed
  122a6fc

• Merge branch 'develop' into batched-kombu-consumer

  gfmio

  authored
  a36799c

• update logging when stopping KombuConsumerWorker

  gfmio

  committed
  e7e9f93

• refactor

  gfmio

  committed
  101ffd9

• refactor

  gfmio

  committed
  6d8e5a3

Commits on Sep 4, 2020

• add requested changes

  gfmio

  committed
  c379e2c

• add type checking stage check

  gfmio

  committed
  ebd8c0b

• add missing None default values

  gfmio

  committed
  8ee318f

• remove Union

  gfmio

  committed
  8fc0ecd

• use Protocol for type annotation

  gfmio

  committed
  d778f57

• check for import errors

  gfmio

  committed
  6adb714

• make fmt

  gfmio

  committed
  392daf4

Commits on Sep 8, 2020

• add requested changes

  gfmio

  committed
  ca3d40e

• Merge branch 'develop' into batched-kombu-consumer

  gfmio

  authored
  290ef23

• remove double quotes

  gfmio

  committed
  e19e3b3

• make fmt

  gfmio

  committed
  44dbafe

• Merge branch 'batched-kombu-consumer' of github.com:gfmio/baseplate.py into batched-kombu-consumer

  gfmio

  committed
  207f2c5

Commits on Sep 9, 2020

• add Timer tests

  gfmio

  committed
  a123a12

• add BatchedQueue tests

  gfmio

  committed
  e00b48e

• fix type checking

  gfmio

  committed
  7197840

• fix durations and sleep in batched queue tests

  gfmio

  committed
  1ef406c

Commits on Sep 12, 2020

• fix tests

  gfmio

  committed
  49cb981

Commits on Sep 13, 2020

• fix test imports

  gfmio

  committed
  dab20ee

• add kombu batch processing tests

  gfmio

  committed
  9eb6c56

• fix span tag handling

  gfmio

  committed
  8657df1

• make fmt

  gfmio

  committed
  0101f09

• Merge branch 'develop' into batched-kombu-consumer

  gfmio

  authored
  7d124a5

• make fmt

  gfmio

  committed
  5aa1097

Commits on Sep 16, 2020

• add warning if a message in the unprocessed batch has already been acknowledged

  gfmio

  committed
  3e2ba82

Commits on Sep 17, 2020

• fix message

  gfmio

  committed
  74b6b12

• add requested changes

  gfmio

  committed
  1fda917

• make fmt

  gfmio

  committed
  f735729

Commits on Apr 28, 2021

• Merge branch 'develop' into batched-kombu-consumer

  gfmio

  committed
  c3afd04

• fix uppercase parameters

  gfmio

  committed
  009b8b1

• make span tags deduplicated, comma-separated lists

  gfmio

  committed
  22d98c7

• update kombu floating s to objects in docstrings

  gfmio

  committed
  30811df

• add new args to match shape of the batched and non-batched objects

  gfmio

  committed
  52de7a0

• add better error message

  gfmio

  committed
  a08765f

• remove timer

  gfmio

  committed
  14a73d5

• rework batched queue to work without timer

  gfmio

  committed
  35551d0

• flush batched queue on iteration

  gfmio

  committed
  a540c5e

• remove timer tests

  gfmio

  committed
  4a23d4e

• fix set constructor

  gfmio

  committed
  bcb227b

• sort batch span tags

  gfmio

  committed
  cce29b1

• fix tests

  gfmio

  committed
  6e6793d

• make fmt

  gfmio

  committed
  4b547de

Commits on Jun 22, 2021

• Update baseplate/frameworks/queue_consumer/kombu.py

  Show description for 2ac6f78
  

  gfmio

  and

  pacejackson

  authored
  2ac6f78

• Update baseplate/frameworks/queue_consumer/kombu.py

  Show description for 8a0b476
  

  gfmio

  and

  pacejackson

  authored
  8a0b476

• Update baseplate/frameworks/queue_consumer/kombu.py

  Show description for a9bffa5
  

  gfmio

  and

  pacejackson

  authored
  a9bffa5

• Update baseplate/frameworks/queue_consumer/kombu.py

  Show description for 74e7533
  

  gfmio

  and

  pacejackson

  authored
  74e7533

Commits on Sep 14, 2021

• Update kombu.py

  gfmio

  authored
  9c9461c

• Update kombu.py

  gfmio

  authored
  6318e36

• Update kombu.py

  gfmio

  authored
  ad38add

Commits on Sep 15, 2021

• Update kombu.py

  gfmio

  authored
  6c5ed3f

• Update kombu.py

  gfmio

  authored
  620c0ee

• Update kombu.py

  gfmio

  authored
  35f2b01

• Update kombu.py

  gfmio

  authored
  9a2e574

• Update batched_queue_tests.py

  gfmio

  authored
  4d05d89