steveo

Minor Changes

• 4703bdf: Added option to add a partition key for a topic

Patch Changes

• dfb642a: Adds a check to see if the kafka producer is connected before disconnecting. This prevents an error being thrown for an unconnected producer getting a disconnect call.

Patch Changes

• Updated dependencies [dfb642a]
• Updated dependencies [4703bdf]
  • [email protected]

Patch Changes

• 48cc840: Initial version of the datadog middleware. It will create a steveo.publish and steveo.consume span

Major Changes

• 00e72e8: Use rrule-rust instead of lunartick for rrule strings

Major Changes

• 00e72e8: Use rrule-rust instead of lunartick for rrule strings

Patch Changes

• Updated dependencies [00e72e8]
  • @steveojs/[email protected]
  • @steveojs/[email protected]

Patch Changes

• 06f8a49: Don't fail if no task not called with any arguments

Patch Changes

• 06f8a49: Don't fail if no task not called with any arguments

Patch Changes

• 28fc2b5: Set aws region
• Updated dependencies [06f8a49]
  • @steveojs/[email protected]
  • @steveojs/[email protected]

Patch Changes

• 7f46fa9: Add cloudwatch metric emitter for PG jobs
• Updated dependencies [a87d9d8]
• Updated dependencies [7f46fa9]
• Updated dependencies [6fde555]
  • @steveojs/[email protected]
  • @steveojs/[email protected]

Minor Changes

• a87d9d8: Fixed issue where jobId was not extracted correctly, causing jobs to not repeat. Updated argument handling to extractjobId, ensuring jobs reschedule as expected.
• 7f46fa9: Add pending jobs event

Minor Changes

• a87d9d8: Fixed issue where jobId was not extracted correctly, causing jobs to not repeat. Updated argument handling to extractjobId, ensuring jobs reschedule as expected.
• 7f46fa9: Add pending jobs event
• 6fde555: Upgrade to latest prisma client

• fix concurrency bug with string instead of int

• Fix releasing pool in SQS backend
• Catch error on pool and not trigger runner exception

Make tasksPath optional parameter in configuration to ease upgrade path

• Support for multiprocess runner
• SQS consumer adjustments to not overload runner

• [Bugfix] Fix for kafka producer emitting success early
• Various dep updates

• Support Node 16.x

Steveo 3.0.1

Replaced kafka back end with node-rdkafka

Release v2.3.2

• Ability to publish messages without a task
• Better types for task callbacks