Ankit Chaurasia comments

Results 57 comments of


                                            Ankit Chaurasia

Fix logic to cancel the external job if the TaskInstance is not in a running or deferred state for BigQueryInsertJobOperator

> Just have a quick discussion with @sunank200. We'll yield the event if CancelError was raised , and handle the TaskInstance state check and cancelation in `execute_complete` This approach would...

Fix logic to cancel the external job if the TaskInstance is not in a running or deferred state for BigQueryInsertJobOperator

@thesuperzapper Please take a look I have tested this and it works fine.

Deferrable operator tasks do not call `on_kill` method when fail or restarted

Same here. I have created the PR for BigQuery/InsertJobOperator based on suggestions. Please review : https://github.com/apache/airflow/pull/39442 I have tested it and it works correctly. cc: @thesuperzapper Currently, I have used...

Deferrable operator tasks do not call `on_kill` method when fail or restarted

PR for DataprocCreateClusterOperator: https://github.com/apache/airflow/pull/39446

Deferrable operator tasks do not call `on_kill` method when fail or restarted

PR for DataprocSubmitJobOperator: https://github.com/apache/airflow/pull/39447

Deferrable operator tasks do not call `on_kill` method when fail or restarted

@thesuperzapper also `BaseTrigger` already has task_instance which can be directly be used

Deferrable operator tasks do not call `on_kill` method when fail or restarted

Please re-review: https://github.com/apache/airflow/pull/39442

Deferrable operator tasks do not call `on_kill` method when fail or restarted

Please re-review: https://github.com/apache/airflow/pull/39446

Deferrable operator tasks do not call `on_kill` method when fail or restarted

Please re-review: https://github.com/apache/airflow/pull/39447

Document the partial table use case for different decorators

This is done