Skip to content

Triggerer Process Do Not create new trigger instance to run #21005

Description

@Greetlist

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

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 problems by:
image

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?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

Type

No type
No fields configured for issues without a type.

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions