You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by GitBox <gi...@apache.org> on 2022/01/21 06:57:03 UTC

[GitHub] [airflow] Greetlist opened a new issue #21005: Triggerer Process Do Not create new trigger instance to run

Greetlist opened a new issue #21005:
URL: https://github.com/apache/airflow/issues/21005


   ### Apache Airflow version
   
   2.2.1
   
   ### What happened
   
   When a Deferrable Task which is cleared or generated. This Trigger's TriggererId is NULL,and never change, which cause this trigger is never init and run by triggerer process.
   
   ### What you expected to happen
   
   When a Deferrable Task is generated, It will init and run correctly.
   
   ### How to reproduce
   
   Clear a Deferrable Task.
   I add some log to source code and find out the reason of this problem:
   ![image](https://user-images.githubusercontent.com/18439743/150479992-a6223697-760f-4e8c-b8b7-a3b20a9641e1.png)
   
   First Query:
   ``` is None ``` has a strange behavior, It does not work.
   Second Query:
   when the trigerer_id has a NULL value in database, it can not query correctly.
   
   I fix both problem by:
   ![image](https://user-images.githubusercontent.com/18439743/150480781-c110e240-a1f6-4a3a-9b26-7b15ce274844.png)
   
   
   
   
   
   ### Operating System
   
   Ubuntu 16.04
   
   ### Versions of Apache Airflow Providers
   
   _No response_
   
   ### Deployment
   
   Other
   
   ### Deployment details
   
   1.One Triggerer Process
   2. Three Scheduler
   3. Pecona Mysql 8.0
   
   ### Anything else
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [X] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [airflow] Greetlist commented on issue #21005: Triggerer Process Do Not create new trigger instance to run

Posted by GitBox <gi...@apache.org>.
Greetlist commented on issue #21005:
URL: https://github.com/apache/airflow/issues/21005#issuecomment-1019657265


   I'm willing to make a PR for it, but I don't know how to add a test case. By the way, there is a ```test_trigger.py``` file in tests, Can I just use the file to test this case?


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [airflow] Greetlist commented on issue #21005: Triggerer Process Do Not create new trigger instance to run

Posted by GitBox <gi...@apache.org>.
Greetlist commented on issue #21005:
URL: https://github.com/apache/airflow/issues/21005#issuecomment-1020717977


   I have another PR [#19640](https://github.com/apache/airflow/pull/19640) which has not been Merged yet.I should wait until it is finished so I can start a new PR for this.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [airflow] Greetlist commented on issue #21005: Triggerer Process Do Not create new trigger instance to run

Posted by GitBox <gi...@apache.org>.
Greetlist commented on issue #21005:
URL: https://github.com/apache/airflow/issues/21005#issuecomment-1020717977


   I have another PR [#19640](https://github.com/apache/airflow/pull/19640) which has not been Merged yet.I should wait until it is finished so I can start a new PR for this.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [airflow] potiuk commented on issue #21005: Triggerer Process Do Not create new trigger instance to run

Posted by GitBox <gi...@apache.org>.
potiuk commented on issue #21005:
URL: https://github.com/apache/airflow/issues/21005#issuecomment-1020097256


   I believe so - but do not know too much about it - I think you can start with PR even without tests and the right people will comment there on how to add tests!


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [airflow] potiuk commented on issue #21005: Triggerer Process Do Not create new trigger instance to run

Posted by GitBox <gi...@apache.org>.
potiuk commented on issue #21005:
URL: https://github.com/apache/airflow/issues/21005#issuecomment-1019593968


   Assigned you to it @Greetlist  - can you please make a PR for that one with "Fixes: #21005" in the message (and cc: @andrewgodwin best to review it ), I thin you wil have to add a test case for that one but we can guide you.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org