Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix job polling when currentlyActiveJobsCount = maxJobsToActivate #405

Closed
wants to merge 39 commits into from

Conversation

petar-slavov
Copy link
Contributor

There is a bug right now when currentlyActiveJobsCount = maxJobsToActivate, the client stops polling for new jobs.

Description of the change

Fix job polling when currentlyActiveJobsCount = maxJobsToActivate

Type of change

  • Bug fix
  • New feature
  • Breaking change
  • Documentation update

Checklist

  • I have read the CONTRIBUTING doc
  • I have opened this pull request against the alpha branch
  • I have added tests that prove my fix is effective or that my feature works
  • I have added necessary documentation (if appropriate)

Further comments

[If this is a relatively large or complex change, kick off the discussion by explaining why you chose the solution you did and what alternatives you considered, etc...]

Sorry, something went wrong.

@CLAassistant
Copy link

CLAassistant commented Mar 14, 2025

CLA assistant check
Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you all sign our Contributor License Agreement before we can accept your contribution.
1 out of 2 committers have signed the CLA.

✅ petar-slavov
❌ semantic-release-bot
You have signed the CLA already but the status is still pending? Let us recheck it.

## [8.6.14](camunda/camunda-8-js-sdk@v8.6.13...v8.6.14) (2024-10-24)

### Bug Fixes

* **camunda8:** correctly parse autostart parameter of JobWorker ([cb95946](camunda@cb95946))
* **camunda8:** type variables in async process instance start as never ([3055734](camunda@3055734))
* **lossless-parser:** correctly parse number array ([d69729a](camunda@d69729a)), closes [camunda#258](camunda#258)
* **lossless-parser:** throw on encountering Date, Map, or Set ([bb5d8ea](camunda@bb5d8ea)), closes [camunda#254](camunda#254)
* **zeebe:** do not override explicit ZEEBE_GRPC_ADDRESS with default ZEEBE_ADDRESS ([cd6080f](camunda@cd6080f)), closes [camunda#245](camunda#245)
* **zeebe:** throw on client if array passed as variables to CompleteJob ([40a6316](camunda@40a6316)), closes [camunda#247](camunda#247)

### Features

* **camunda8:** add C8RestClient ([8e93c92](camunda@8e93c92)), closes [camunda#235](camunda#235)
* **camunda8:** add modifyAuthorization method ([0d97f68](camunda@0d97f68))
* **camunda8:** complete deployResources feature ([8043ac9](camunda@8043ac9))
* **camunda8:** implement createProcessInstanceWithResult ([4ec4fa1](camunda@4ec4fa1))
* **camunda8:** implement deleteResource over REST ([1dcb101](camunda@1dcb101)), closes [camunda#251](camunda#251)
* **camunda8:** implement deployResources REST API ([debd212](camunda@debd212))
* **camunda8:** implement publishMessage over REST ([057a9fe](camunda@057a9fe)), closes [camunda#250](camunda#250)
* **camunda8:** support broadcastSignal over REST ([43f82a4](camunda@43f82a4)), closes [camunda#248](camunda#248)
* **camunda8:** support pluggable winston logging for C8RestClient ([d41d3f8](camunda@d41d3f8))
* **camunda8:** support updateElementInstanceVariables ([7de82b7](camunda@7de82b7)), closes [camunda#249](camunda#249)
* **repo:** support passing middleware ([1b7715e](camunda@1b7715e)), closes [camunda#261](camunda#261)
* **zeebe:** add operationReference field to gRPC methods ([2e5af66](camunda@2e5af66)), closes [camunda#237](camunda#237)
* **zeebe:** create and cancel process instances over REST ([a49d217](camunda@a49d217))
* **zeebe:** lossless parse REST variables and customheaders ([f19a252](camunda@f19a252)), closes [camunda#244](camunda#244)
## [8.6.14](camunda/camunda-8-js-sdk@v8.6.13...v8.6.14) (2024-10-24)

### Bug Fixes

* **camunda8:** correctly parse autostart parameter of JobWorker ([cb95946](camunda@cb95946))
* **camunda8:** type variables in async process instance start as never ([3055734](camunda@3055734))
* **lossless-parser:** correctly parse number array ([d69729a](camunda@d69729a)), closes [camunda#258](camunda#258)
* **lossless-parser:** throw on encountering Date, Map, or Set ([bb5d8ea](camunda@bb5d8ea)), closes [camunda#254](camunda#254)
* **zeebe:** do not override explicit ZEEBE_GRPC_ADDRESS with default ZEEBE_ADDRESS ([cd6080f](camunda@cd6080f)), closes [camunda#245](camunda#245)
* **zeebe:** throw on client if array passed as variables to CompleteJob ([40a6316](camunda@40a6316)), closes [camunda#247](camunda#247)

### Features

* **camunda8:** add C8RestClient ([8e93c92](camunda@8e93c92)), closes [camunda#235](camunda#235)
* **camunda8:** add modifyAuthorization method ([0d97f68](camunda@0d97f68))
* **camunda8:** complete deployResources feature ([8043ac9](camunda@8043ac9))
* **camunda8:** implement createProcessInstanceWithResult ([4ec4fa1](camunda@4ec4fa1))
* **camunda8:** implement deleteResource over REST ([1dcb101](camunda@1dcb101)), closes [camunda#251](camunda#251)
* **camunda8:** implement deployResources REST API ([debd212](camunda@debd212))
* **camunda8:** implement publishMessage over REST ([057a9fe](camunda@057a9fe)), closes [camunda#250](camunda#250)
* **camunda8:** support broadcastSignal over REST ([43f82a4](camunda@43f82a4)), closes [camunda#248](camunda#248)
* **camunda8:** support pluggable winston logging for C8RestClient ([d41d3f8](camunda@d41d3f8))
* **camunda8:** support updateElementInstanceVariables ([7de82b7](camunda@7de82b7)), closes [camunda#249](camunda#249)
* **repo:** support passing middleware ([1b7715e](camunda@1b7715e)), closes [camunda#261](camunda#261)
* **zeebe:** add operationReference field to gRPC methods ([2e5af66](camunda@2e5af66)), closes [camunda#237](camunda#237)
* **zeebe:** create and cancel process instances over REST ([a49d217](camunda@a49d217))
* **zeebe:** lossless parse REST variables and customheaders ([f19a252](camunda@f19a252)), closes [camunda#244](camunda#244)
## [8.6.15](camunda/camunda-8-js-sdk@v8.6.14...v8.6.15) (2024-10-24)

### Bug Fixes

* **modeler:** correct HTTP methods for file methods. fixes [camunda#269](camunda#269) ([7819baa](camunda@7819baa))
## [8.6.15](camunda/camunda-8-js-sdk@v8.6.14...v8.6.15) (2024-10-24)

### Bug Fixes

* **modeler:** correct HTTP methods for file methods. fixes [camunda#269](camunda#269) ([7819baa](camunda@7819baa))
## [8.6.16](camunda/camunda-8-js-sdk@v8.6.15...v8.6.16) (2024-11-15)

### Features

* **authorization:** add bearer token authorization ([f7d1ff3](camunda@f7d1ff3))
## [8.6.16](camunda/camunda-8-js-sdk@v8.6.15...v8.6.16) (2024-11-15)

### Features

* **authorization:** add bearer token authorization ([f7d1ff3](camunda@f7d1ff3))
## [8.6.17](camunda/camunda-8-js-sdk@v8.6.16...v8.6.17) (2024-12-19)

### Bug Fixes

* **zeebe:** update JS GPRC lib dependency, release stream resources on end ([89fd95c](camunda@89fd95c))
## [8.6.17](camunda/camunda-8-js-sdk@v8.6.16...v8.6.17) (2024-12-19)

### Bug Fixes

* **zeebe:** update JS GPRC lib dependency, release stream resources on end ([89fd95c](camunda@89fd95c))
## [8.6.18](camunda/camunda-8-js-sdk@v8.6.17...v8.6.18) (2024-12-20)

### Bug Fixes

* **modeler:** update SaaS URL for Modeler ([563e866](camunda@563e866))
## [8.6.18](camunda/camunda-8-js-sdk@v8.6.17...v8.6.18) (2024-12-20)

### Bug Fixes

* **modeler:** update SaaS URL for Modeler ([563e866](camunda@563e866))
## [8.6.19](camunda/camunda-8-js-sdk@v8.6.18...v8.6.19) (2025-01-23)

### Bug Fixes

* **zeebe:** propagate 'NOT_FOUND' error on job.complete(). fixes [camunda#351](camunda#351) ([59ebf5d](camunda@59ebf5d))
## [8.6.19](camunda/camunda-8-js-sdk@v8.6.18...v8.6.19) (2025-01-23)

### Bug Fixes

* **zeebe:** propagate 'NOT_FOUND' error on job.complete(). fixes [camunda#351](camunda#351) ([59ebf5d](camunda@59ebf5d))
## [8.6.20](camunda/camunda-8-js-sdk@v8.6.19...v8.6.20) (2025-01-23)

### Bug Fixes

* **zeebe:** catch exception in fail job on unhandled exception in job handler. fixes [camunda#351](camunda#351) ([91e7213](camunda@91e7213))
* **zeebe:** do not fail jobs that are already not found ([448575c](camunda@448575c))
## [8.6.20](camunda/camunda-8-js-sdk@v8.6.19...v8.6.20) (2025-01-23)

### Bug Fixes

* **zeebe:** catch exception in fail job on unhandled exception in job handler. fixes [camunda#351](camunda#351) ([91e7213](camunda@91e7213))
* **zeebe:** do not fail jobs that are already not found ([448575c](camunda@448575c))
## [8.6.21](camunda/camunda-8-js-sdk@v8.6.20...v8.6.21) (2025-01-24)

### Bug Fixes

* **zeebe:** move polling blocked log message to new verbose level. fixes [camunda#356](camunda#356) ([62c1459](camunda@62c1459))
## [8.6.21](camunda/camunda-8-js-sdk@v8.6.20...v8.6.21) (2025-01-24)

### Bug Fixes

* **zeebe:** move polling blocked log message to new verbose level. fixes [camunda#356](camunda#356) ([62c1459](camunda@62c1459))
## [8.6.22](camunda/camunda-8-js-sdk@v8.6.21...v8.6.22) (2025-02-04)

### Features

* **zeebe:** implement backoff on UNAUTHENTICATED error for workers ([56c3c78](camunda@56c3c78)), closes [camunda#366](camunda#366)
## [8.6.22](camunda/camunda-8-js-sdk@v8.6.21...v8.6.22) (2025-02-04)

### Features

* **zeebe:** implement backoff on UNAUTHENTICATED error for workers ([56c3c78](camunda@56c3c78)), closes [camunda#366](camunda#366)
## [8.6.23](camunda/camunda-8-js-sdk@v8.6.22...v8.6.23) (2025-02-05)

### Bug Fixes

* **oauth:** pass out full auth header from getToken method ([55a19b6](camunda@55a19b6)), closes [camunda#367](camunda#367)
## [8.6.23](camunda/camunda-8-js-sdk@v8.6.22...v8.6.23) (2025-02-05)

### Bug Fixes

* **oauth:** pass out full auth header from getToken method ([55a19b6](camunda@55a19b6)), closes [camunda#367](camunda#367)
## [8.6.24](camunda/camunda-8-js-sdk@v8.6.23...v8.6.24) (2025-02-12)

### Features

* **zeebe:** support 8.7 string entity keys (backwards-compatible with int64) ([1ea31f0](camunda@1ea31f0)), closes [camunda#279](camunda#279)
## [8.6.24](camunda/camunda-8-js-sdk@v8.6.23...v8.6.24) (2025-02-12)

### Features

* **zeebe:** support 8.7 string entity keys (backwards-compatible with int64) ([1ea31f0](camunda@1ea31f0)), closes [camunda#279](camunda#279)
## [8.6.25](camunda/camunda-8-js-sdk@v8.6.24...v8.6.25) (2025-02-17)

### Bug Fixes

* **zeebe:** throw UNAUTHENTICATED error on ActivateJobs from stream.error event ([d44029e](camunda@d44029e)), closes [camunda#378](camunda#378)
## [8.6.25](camunda/camunda-8-js-sdk@v8.6.24...v8.6.25) (2025-02-17)

### Bug Fixes

* **zeebe:** throw UNAUTHENTICATED error on ActivateJobs from stream.error event ([d44029e](camunda@d44029e)), closes [camunda#378](camunda#378)
## [8.6.26](camunda/camunda-8-js-sdk@v8.6.25...v8.6.26) (2025-02-26)

### Bug Fixes

* **repo:** close backoff timers on worker close ([405595a](camunda@405595a))

### Features

* **camunda:** implement backoff on errors for REST job worker ([4895942](camunda@4895942)), closes [camunda#370](camunda#370)
## [8.6.26](camunda/camunda-8-js-sdk@v8.6.25...v8.6.26) (2025-02-26)

### Bug Fixes

* **repo:** close backoff timers on worker close ([405595a](camunda@405595a))

### Features

* **camunda:** implement backoff on errors for REST job worker ([4895942](camunda@4895942)), closes [camunda#370](camunda#370)
## [8.6.27](camunda/camunda-8-js-sdk@v8.6.26...v8.6.27) (2025-02-27)

### Bug Fixes

* **camunda8:** add optional tenantId to deployResourcesFromFiles ([dff868e](camunda@dff868e)), closes [camunda#375](camunda#375)

### Features

* **camunda8:** add queryVariables method. fixes [camunda#343](camunda#343) ([b361d71](camunda@b361d71))
* **camunda8:** implement findUserTasks ([d2baa70](camunda@d2baa70)), closes [camunda#341](camunda#341)
* **camunda:** implement getUserTask. fixes [camunda#339](camunda#339) ([8bcb59a](camunda@8bcb59a))
## [8.6.27](camunda/camunda-8-js-sdk@v8.6.26...v8.6.27) (2025-02-27)

### Bug Fixes

* **camunda8:** add optional tenantId to deployResourcesFromFiles ([dff868e](camunda@dff868e)), closes [camunda#375](camunda#375)

### Features

* **camunda8:** add queryVariables method. fixes [camunda#343](camunda#343) ([b361d71](camunda@b361d71))
* **camunda8:** implement findUserTasks ([d2baa70](camunda@d2baa70)), closes [camunda#341](camunda#341)
* **camunda:** implement getUserTask. fixes [camunda#339](camunda#339) ([8bcb59a](camunda@8bcb59a))
## [8.6.28](camunda/camunda-8-js-sdk@v8.6.27...v8.6.28) (2025-02-28)

### Bug Fixes

* **camunda8:** remove experimental decorator ([809fe9b](camunda@809fe9b))
semantic-release-bot and others added 10 commits March 14, 2025 12:13
## [8.6.28](camunda/camunda-8-js-sdk@v8.6.27...v8.6.28) (2025-02-28)

### Bug Fixes

* **camunda8:** remove experimental decorator ([809fe9b](camunda@809fe9b))
## [8.6.29](camunda/camunda-8-js-sdk@v8.6.28...v8.6.29) (2025-03-04)

### Bug Fixes

* fix searchUserTasks ([a39ad05](camunda@a39ad05))
## [8.6.29](camunda/camunda-8-js-sdk@v8.6.28...v8.6.29) (2025-03-04)

### Bug Fixes

* fix searchUserTasks ([a39ad05](camunda@a39ad05))
## [8.6.30](camunda/camunda-8-js-sdk@v8.6.29...v8.6.30) (2025-03-05)

### Features

* **camunda8:** support getUserTask (8.8) ([26e0507](camunda@26e0507))
* **camunda:** implement getUserTaskVariables ([6dd59f6](camunda@6dd59f6)), closes [camunda#342](camunda#342)
* **camunda:** implement searchProcessInstances. fixes [camunda#320](camunda#320) ([bce0eb1](camunda@bce0eb1))
## [8.6.30](camunda/camunda-8-js-sdk@v8.6.29...v8.6.30) (2025-03-05)

### Features

* **camunda8:** support getUserTask (8.8) ([26e0507](camunda@26e0507))
* **camunda:** implement getUserTaskVariables ([6dd59f6](camunda@6dd59f6)), closes [camunda#342](camunda#342)
* **camunda:** implement searchProcessInstances. fixes [camunda#320](camunda#320) ([bce0eb1](camunda@bce0eb1))
## [8.6.31](camunda/camunda-8-js-sdk@v8.6.30...v8.6.31) (2025-03-05)

### Bug Fixes

* use ZEEBE_TOKEN_AUDIENCE if set ([ac46921](camunda@ac46921)), closes [camunda#392](camunda#392)
## [8.6.31](camunda/camunda-8-js-sdk@v8.6.30...v8.6.31) (2025-03-05)

### Bug Fixes

* use ZEEBE_TOKEN_AUDIENCE if set ([ac46921](camunda@ac46921)), closes [camunda#392](camunda#392)
## [8.6.32](camunda/camunda-8-js-sdk@v8.6.31...v8.6.32) (2025-03-06)

### Bug Fixes

* add tests and documentation for logging ([3522faf](camunda@3522faf)), closes [camunda#397](camunda#397)
* **operate:** allow paging for getVariablesforProcess ([b94532d](camunda@b94532d)), closes [camunda#387](camunda#387)
## [8.6.32](camunda/camunda-8-js-sdk@v8.6.31...v8.6.32) (2025-03-06)

### Bug Fixes

* add tests and documentation for logging ([3522faf](camunda@3522faf)), closes [camunda#397](camunda#397)
* **operate:** allow paging for getVariablesforProcess ([b94532d](camunda@b94532d)), closes [camunda#387](camunda#387)
There is a bug right now when currentlyActiveJobsCount = maxJobsToActivate, the client stops polling for new jobs.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

3 participants