conductor-python issues

KafkaPublishInput missing swagger attributes

1

As for now it's impossible for me to use KafkaPublish task due to swagger issue. I've added a KafkaPublishTask to my workflow, it looks like this: ``` def send_kafka_message_task( workflow_id:...

vyshnevskyi

Register workflow with override=true still generates a 409 error

1

If we look at how the Java SDK is implemented, ``` public boolean registerWorkflow(WorkflowDef workflowDef, boolean overwrite) { try { if (overwrite) { metadataClient.updateWorkflowDefs(Arrays.asList(workflowDef)); } else { metadataClient.registerWorkflowDef(workflowDef); } return...

andyren0110

Integration tests depend on already created workflows

There are two sets of integration tests, one for testing registration, the other execution. The registration test tries to register a workflow, which requires simple tasks and sub-workflow to be...

marcocrasso

enhancement

Improve TaskHandler polling strategy

1

- Add new parameter for `batchSize` - Each worker will have a standalone subprocess to poll indefinitely - For each polled task, start a new subprocess to execute and update...

gardusig

enhancement

PicklingError When Running helloworld Script

3

Hi everyone 👋, I'm encountering a problem when trying to run the helloworld script. The error message I receive is a PicklingError related to multiprocessing. It seems that the issue...

Ivancles

Memory Continually Increasing Intermittently

7

Hello everyone, My team seems to have stumbled upon a really weird issue with the conductor python sdk where the memory of the worker continues to climb until the worker...

ryorke1

Hello World Example Not Working

3

While runing python conductor I am getting following error. EOFError: Ran out of input: The detailed stacktrace is given below: ```(venv) F:\differentbyte\conductor_test>python helloworld.py 2024-10-03 22:01:21,229 [13468] conductor.client.automator.task_handler INFO created worker...

arunksoman