ai-flow
ai-flow copied to clipboard
AI Flow is an open source framework that bridges big data and artificial intelligence.
## What is the purpose of the change *(For example: This pull request makes user can stop workflow externally.)* ## Brief change log *(for example:)* - *Send StopDagEvent to Airflow...
### Describe the bug task1 action_on_task_status(task2, success) when task1 failed, task2 would not be scheduled, but the status of workflow execution is still running. I think the status shoud be...
### Describe the feature Currently, the event is broadcasting, once the wanted event is sent, all workflow executions of this workflow would be triggered. ### Describe the solution you'd like...
### Describe the bug ### Your environment #### Operating system #### Database #### Python version ### To Reproduce Steps to reproduce the behavior (if you can): 1. Submit a '...'...
### Describe the feature AIFlow support python3.6 ### Describe the solution you'd like ### Describe alternatives you've considered ### Additional context When run aiflow with python3.6, notification server blocks wich...
### Describe the bug Cannot use one EmbeddedNotificationClient instance in multiple threads. ### Your environment #### Operating system #### Database #### Python version ### To Reproduce ``` def test_create_client_multiple_threads(self): import...
### Describe the feature Now a job triggerd by event can access to the event by `list_events` and then get the lateset event, is there a more intuitive way? ###...
### Describe the feature [AIFlow]Simplify the python libraries
### Describe the feature Job's logs can only be generated by print, hoping `logging` can work, ### Describe the solution you'd like ### Describe alternatives you've considered ### Additional context
### Describe the feature [AIFlow]Job add configure python environment