[GitHub] [airflow] phanikumv commented on a diff in pull request #29300: Add deferrable BatchOperator

2023-03-31 Thread via GitHub
phanikumv commented on code in PR #29300: URL: https://github.com/apache/airflow/pull/29300#discussion_r1154541102 ## tests/providers/amazon/aws/operators/test_batch.py: ## @@ -211,3 +218,114 @@ def test_execute(self, mock_conn): computeResources=compute_resources,

[GitHub] [airflow] phanikumv commented on a diff in pull request #29300: Add deferrable BatchOperator

2023-03-29 Thread via GitHub
phanikumv commented on code in PR #29300: URL: https://github.com/apache/airflow/pull/29300#discussion_r1152789008 ## airflow/providers/amazon/aws/hooks/batch_client.py: ## @@ -544,3 +546,240 @@ def exp(tries): delay = 1 + pow(tries * 0.6, 2) delay = min(max_in

[GitHub] [airflow] phanikumv commented on a diff in pull request #29300: Add deferrable BatchOperator

2023-02-21 Thread via GitHub
phanikumv commented on code in PR #29300: URL: https://github.com/apache/airflow/pull/29300#discussion_r1113081966 ## airflow/providers/amazon/aws/hooks/base_aws.py: ## @@ -865,3 +868,85 @@ def _parse_s3_config(config_file_name: str, config_format: str | None = "boto",