taskiq-pipelines

taskiq-pipelines copied to clipboard

Add test for pipelines

4

I'm not really sure how to test it, but we have to.

s3rius

Switch to broker.serializer instead of JSON-only solution

2

The code works well but contains a dirty hack for parsing pipeline data from task labels. Pipeline `loads()`/`dumps()` are `loadb()`/`dumpb()` now. Step's `loads()`/`dumps()` are gone away, seems like they don't...

asvetlov

Support non-json serializers

4

Hey! Thank you for the library. For some reason, I would use CBOR serializer instead of JSON. The system could be configured easily enough by overloading `Pipeline` and `AbstractStep` `dumps()`...

asvetlov

Often we need to do different sets of actions based on the result of the execution of some function. Here we can discuss the API and how it can be...

s3rius

Add a schedule for pipeline tasks

2

Hello! How to schedule pipeline tasks?

casper-71

s3rius

I was trying to build a pipeline where I would have a list of tuples being returned from the first sequential task into a mapper, that should take one of...

fubuloubu

Empty `.map` pipeline never completes

1

I have a pipeline task that's like `Pipeline(broker, produces_array).map(another_task)` but it never completes when I want using `task.wait_result` if `produces_array` returns an empty list

fubuloubu