Skip to content
This repository was archived by the owner on Jun 8, 2023. It is now read-only.

Releases: quantmind/pulsar-queue

0.5.2

28 Nov 20:25

Choose a tag to compare

Obfuscate consumer urls

0.5.1

25 Nov 08:10

Choose a tag to compare

Several internal changes and bug fixes

  • Dropped pubsub in favour of pulsar channels
  • Redis backend uses namespace for both channels and queues
  • Better serialisation support for messages
  • Added register_broker function to api
  • Added queue_message function to api

0.5.0

11 Oct 15:40

Choose a tag to compare

Backward incompatible release with a considerable amount of internal and API refactoring

  • Ability to add additional consumers to the queue server (see pulsar-twitter for example)
  • Each consumer is an attribute of the server queue api and backend objects
  • Renamed TaskFuture to MessageFuture
  • Handle max_retries with retry_delay
  • TaskError can be used in order to avoid a full stack trace dump. It means it is a TaskError handled by the Job callable.
  • Added timeout to task execution
  • Max concurrent tasks is a linear function of number of cores and concurrent_tasks parameter

0.4.0

04 Aug 21:57

Choose a tag to compare

Several backward incompatible changes. This version is not compatible with the 0.3 series
and brings several bug fixes, enhancements and almost 100% test coverage.

  • Added TaskManager for better customise the task queue application
  • Added message serialisers - json and msgpack
  • Consumers can run on a single process b392f82
  • Allow to queue tasks with a delay 3ed7d7a
  • Handle drop connections from pubsub and message queue broker
  • Enhanced documentation

0.3.1

09 Jul 16:40

Choose a tag to compare

  • Increased code coverage
  • Fixed RPC server
  • Increased documentation
  • Bug and API fixes

0.3.0

01 Jul 15:40

Choose a tag to compare

  • Major code refactoring with introduction of submodules
  • Task queue Backend has Pubsub and Message queue handlers

0.2.0

12 May 08:41

Choose a tag to compare

  • Works for python 3.5 and above
  • Increased test coverage
  • New test suite
  • Development status set to Alpha

First Official Release

26 Nov 16:46

Choose a tag to compare

Internals

  • Run the CPUBOUND tasks in a child greenlet