Code

Add queue flushing signal handler#792

Code

Open

atai92 wants to merge 9 commits intoreddit:developreddit/baseplate.py:developfrom atai92:add_queue_flushing_signal_handleratai92/baseplate.py:add_queue_flushing_signal_handlerCopy head branch name to clipboard

+41-6

Commits

Commits on Jan 25, 2023

• Added flush queue signal handler within event publisher.

  

  Alan Tai

  committed
  ccad13a

  Copy full SHA for ccad13a

• Linting and formatting.

  

  Alan Tai

  committed
  9c7ec10

  Copy full SHA for 9c7ec10

Commits on Jan 26, 2023

• Updating is_ready to simply return the result of the condition

  

  Alan Tai

  committed
  0c71eba

  Copy full SHA for 0c71eba

Commits on Mar 16, 2023

• Merge branch 'develop' into add_queue_flushing_signal_handler

  KTAtkinson

  authored
  1e974ab

  Copy full SHA for 1e974ab

Commits on May 16, 2023

• Updating to use try add batcher msg instead of checking whether the property is true.

  

  Alan Tai

  committed
  6b3828c

  Copy full SHA for 6b3828c

• Removing property for is_full since it is not useful anymore.

  

  Alan Tai

  committed
  017b538

  Copy full SHA for 017b538

Commits on May 17, 2023

• Adding missing batcher.add(message) after publishing batch, so we don't drop the message that failed to publish.

  

  Alan Tai

  committed
  75b13c2

  Copy full SHA for 75b13c2

• Lint.

  

  Alan Tai

  committed
  fec5c07

  Copy full SHA for fec5c07

• Merge branch 'develop' into add_queue_flushing_signal_handler

  atai92

  authored
  cb60ac6

  Copy full SHA for cb60ac6