Skip to content

Releases: AmberEngine/stepfunctions_activity_worker

Task Timeout Fix

16 Oct 17:44
11cfcb6
Compare
Choose a tag to compare
  • Activity worker will release the semaphore when send_task_success raises a client error

Semaphore Activity Worker Control

28 Feb 20:23
Compare
Choose a tag to compare
Semaphore Worker Count Control (#9)

* address heartbeat timeout edge case

* revert back to using threadpools instead of process pools

* now properly tested

* remove debug code

* clarify docstring

* unnecessary magic num

* Tweak semaphore tests

Change ThreadPoolExecutor => ProcessPollExecutor

25 Feb 20:15
Compare
Choose a tag to compare
Change ThreadPoolExecutor => ProcessPoolExecutor (#8)

* change concurrent executor from thread to process

* increment version

Listener Threading

21 Feb 16:01
97a3059
Compare
Choose a tag to compare

When instantiating the ActivityWorker you can now specify worker_count= to specify how many workers you would like to have running in parallel when using ActivityWorker.listen().

Default is worker_count=1.

Initial Release

29 Nov 18:35
40693fe
Compare
Choose a tag to compare

The first release!

This initial release completely encapsulates all the work that goes into communicating with the StepFunctions API; all you need to do is provide a function that takes task input and returns task output!