conductor-python

conductor-python copied to clipboard

FhffjGdxjsjfmxjdjcmxjfxsjchshvxnbzhxjhzhcb57676767676765686356767676434646477xjjdjdudjxjxjdysyfkgigogogidfhdkh fickckckjcickckcjckcjcudj JC HD f if so Islamists ICICI ufff ufff ofc kuch j ggxuuduoogdsgjg icon Ha

anjillakra

Added a new client to manage environment variables.

coderabhigupta

TypeError: 'type' object is not subscriptable

4

Hello everyone, I get this error while importing the `Worker` class: ``` from conductor.client.worker.worker import Worker ../../.local/lib/python3.8/site-packages/conductor/client/worker/worker.py:14: in from conductor.client.http.api_client import ApiClient ../../.local/lib/python3.8/site-packages/conductor/client/http/api_client.py:15: in import conductor.client.http.models as http_models ../../.local/lib/python3.8/site-packages/conductor/client/http/models/__init__.py:34: in...

andreapairon

Get AuthorizationException when trying to update variables of a started workflow

2

I'm trying to set some workflow variables just after starting a workflow with this code: ```python clients = OrkesClients(configuration=config) executor = WorkflowExecutor(config) runner = clients.get_workflow_client() request = StartWorkflowRequest( name="flow", correlation_id="corr_id",...

jruizaranguren

Added extendLease as task_router param

4

- The task with `extendLease` set to `True` won't be rescheduled by the Conductor unless it gets timed out with `RETRY` set as timeoutPolicy. Note: The feature is already implemented...

shalindeval

v1r3n

Support for asyncio based workers

1

The current worker implementation model uses multiprocessing for parallel execution but each process blocks on task execution (though it might be waiting on I/O). Is there a possibility to use...

aditya-n-invcr

Workers graceful shutdown being sure that current executions are not truncated

3

Hi everyone, I have Conductor workers running on Kubernetes pods. I would like to handle the graceful shutdown in this way: 1. stop worker polling (I achieved this by implementing...

andreapairon

Conductor API for updateWorkflowDef doesn't support updating onStateChange values

1

Conductor API for updateWorkflowDef doesn't support updating onStateChange values. ``` task.on_state_change = { "onScheduled,onStart,onSuccess,onFailed,onCancelled": [ { "type": "task_status_changed", "payload": {"task": "${%s}" % task.task_reference_name, "workflow": "${workflow}"}, } ] } ``` but...

matteius

I spent some time trying to debug this Friday and from what I can gather, issuing SIGTERM to a python process that has spawned from the following pattern ignores SIGTERM...

matteius