Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-11-14 Thread via GitHub
mobuchowski merged PR #35090: URL: https://github.com/apache/airflow/pull/35090 -- 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-unsubscr...@airf

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-11-06 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1382929616 ## airflow/providers/amazon/aws/hooks/athena.py: ## @@ -121,7 +122,26 @@ def run_query( self.log.info("Query execution id: %s", query_execution_id)

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-27 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1374477084 ## airflow/providers/amazon/aws/hooks/athena.py: ## @@ -121,7 +122,26 @@ def run_query( self.log.info("Query execution id: %s", query_execution_id)

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-27 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1374475519 ## airflow/providers/amazon/aws/hooks/athena.py: ## @@ -121,7 +122,26 @@ def run_query( self.log.info("Query execution id: %s", query_execution_id)

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-27 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1374379872 ## airflow/providers/amazon/aws/hooks/athena.py: ## @@ -121,7 +122,26 @@ def run_query( self.log.info("Query execution id: %s", query_execution_id)

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-27 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1374398638 ## airflow/providers/amazon/aws/hooks/athena.py: ## @@ -121,7 +122,26 @@ def run_query( self.log.info("Query execution id: %s", query_execution_id)

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-27 Thread via GitHub
Taragolis commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1374380605 ## airflow/providers/amazon/aws/hooks/athena.py: ## @@ -121,7 +122,26 @@ def run_query( self.log.info("Query execution id: %s", query_execution_id)

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-27 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1374379872 ## airflow/providers/amazon/aws/hooks/athena.py: ## @@ -121,7 +122,26 @@ def run_query( self.log.info("Query execution id: %s", query_execution_id)

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-27 Thread via GitHub
Taragolis commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1374362958 ## airflow/providers/amazon/aws/hooks/athena.py: ## @@ -121,7 +122,26 @@ def run_query( self.log.info("Query execution id: %s", query_execution_id)

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-25 Thread via GitHub
mobuchowski commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1371557024 ## airflow/providers/amazon/aws/hooks/athena.py: ## @@ -121,7 +122,26 @@ def run_query( self.log.info("Query execution id: %s", query_execution_id)

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-24 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1370914455 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-24 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1370913555 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-23 Thread via GitHub
eladkal commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1369651269 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id %s

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-22 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367912424 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-22 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367912424 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-22 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367912424 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-22 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367912424 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-22 Thread via GitHub
Taragolis commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367911627 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-22 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367892633 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-22 Thread via GitHub
JDarDagran commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367892219 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-22 Thread via GitHub
Taragolis commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r136755 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-22 Thread via GitHub
Taragolis commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r136755 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-21 Thread via GitHub
eladkal commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367841685 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id %s

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-21 Thread via GitHub
Taragolis commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367799591 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-21 Thread via GitHub
eladkal commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367768708 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id %s

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-21 Thread via GitHub
eladkal commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367768793 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id %s

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-21 Thread via GitHub
eladkal commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367768793 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id %s

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-21 Thread via GitHub
eladkal commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367768708 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id %s

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-21 Thread via GitHub
eladkal commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367768793 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id %s

Re: [PR] openlineage, aws: Add OpenLineage support for AthenaOperator. [airflow]

2023-10-21 Thread via GitHub
eladkal commented on code in PR #35090: URL: https://github.com/apache/airflow/pull/35090#discussion_r1367768708 ## airflow/providers/amazon/aws/operators/athena.py: ## @@ -163,3 +167,132 @@ def on_kill(self) -> None: "Polling Athena for query with id %s