Re: [PR] Add druid ingestion connection test [airflow]

2023-10-21 Thread via GitHub
eladkal commented on code in PR #33796: URL: https://github.com/apache/airflow/pull/33796#discussion_r1367842425 ## airflow/providers/apache/druid/CHANGELOG.rst: ## @@ -27,6 +27,19 @@ Changelog - +4.0.0 +. + +Features + + +* ``Add druid ingestion

Re: [PR] Add druid ingestion connection test [airflow]

2023-10-21 Thread via GitHub
eladkal commented on code in PR #33796: URL: https://github.com/apache/airflow/pull/33796#discussion_r1367842425 ## airflow/providers/apache/druid/CHANGELOG.rst: ## @@ -27,6 +27,19 @@ Changelog - +4.0.0 +. + +Features + + +* ``Add druid ingestion

Re: [PR] Yandex dataproc deduce default service account [airflow]

2023-10-21 Thread via GitHub
eladkal commented on PR #35059: URL: https://github.com/apache/airflow/pull/35059#issuecomment-1774002746 Static checks are failing -- 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

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

Re: [PR] bump open api image to v7.0.1 [airflow]

2023-10-21 Thread via GitHub
eladkal commented on code in PR #34805: URL: https://github.com/apache/airflow/pull/34805#discussion_r1367841259 ## clients/gen/common.sh: ## @@ -17,7 +17,7 @@ # specific language governing permissions and limitations # under the License. -OPENAPI_GENERATOR_CLI_VER=5.4.0

Re: [PR] Enable encryption in S3 download_files() hook. [airflow]

2023-10-21 Thread via GitHub
eladkal commented on code in PR #35037: URL: https://github.com/apache/airflow/pull/35037#discussion_r1367840823 ## airflow/providers/amazon/aws/hooks/s3.py: ## @@ -912,14 +912,24 @@ def get_key(self, key: str, bucket_name: str | None = None) -> S3ResourceObject:

Re: [PR] Added "overrides" parameter for CloudRunExecuteJobOperator [airflow]

2023-10-21 Thread via GitHub
amoghrajesh commented on code in PR #34874: URL: https://github.com/apache/airflow/pull/34874#discussion_r1367835597 ## airflow/providers/google/cloud/operators/cloud_run.py: ## @@ -270,6 +271,7 @@ def __init__( project_id: str, region: str, job_name:

Re: [I] Airflow web doesn't work when set sql_alchemy_pool_enabled to false [airflow]

2023-10-21 Thread via GitHub
zhenghanyang commented on issue #34950: URL: https://github.com/apache/airflow/issues/34950#issuecomment-1773978385 Yes, then just comment following three lines in "/home/airflow/.local/lib/python3.8/site-packages/flask_sqlalchemy/__init__.py", webserver can work normally. ```python

Re: [PR] Improve clear_not_launched_queued_tasks call duration [airflow]

2023-10-21 Thread via GitHub
dirrao commented on PR #34985: URL: https://github.com/apache/airflow/pull/34985#issuecomment-1773974950 @hussein-awala Did you get a chance to test it? Any findings? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] Update synapse.py to fix timeout bug [airflow]

2023-10-21 Thread via GitHub
github-actions[bot] commented on PR #33900: URL: https://github.com/apache/airflow/pull/33900#issuecomment-1773951712 This pull request has been automatically marked as stale because it has not had recent activity. It will be closed in 5 days if no further activity occurs. Thank you for

Re: [PR] Take into account removed upstream tasks for non-mapped tasks. [airflow]

2023-10-21 Thread via GitHub
github-actions[bot] closed pull request #33915: Take into account removed upstream tasks for non-mapped tasks. URL: https://github.com/apache/airflow/pull/33915 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] Unflake test_volume_mount in k8s tests [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #35106: URL: https://github.com/apache/airflow/pull/35106#issuecomment-1773950066 Example flaky failure here: https://github.com/apache/airflow/actions/runs/6598526836/job/17926985195 -- This is an automated message from the Apache Git Service. To respond to the

[PR] Unflake test_volume_mount in k8s tests [airflow]

2023-10-21 Thread via GitHub
potiuk opened a new pull request, #35106: URL: https://github.com/apache/airflow/pull/35106 The `test_volume_mount` in k8s relied on "retrieved from mount\n" printed to log as retrieved from K8S pod. Howver, due to the way how logs are retrieved, sometimes the log printed contains the EOL

Re: [PR] FTPHook methods should not change working directory [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #35105: URL: https://github.com/apache/airflow/pull/35105#issuecomment-1773933323 This should be idone via try/finally or (better) following context_manager (and tests shoudl be fixed) -- This is an automated message from the Apache Git Service. To respond to the

Re: [PR] Displaying "actual" try number in TaskInstance view [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #34635: URL: https://github.com/apache/airflow/pull/34635#issuecomment-1773932972 docs need fixing for that one (and rebase). -- 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

[airflow] branch constraints-main updated: Updating constraints. Github run id:6599164384

2023-10-21 Thread github-bot
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch constraints-main in repository https://gitbox.apache.org/repos/asf/airflow.git The following commit(s) were added to refs/heads/constraints-main by this push: new 256cc90644 Updating

Re: [PR] Migrate provider-specific executor docs to providers [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #34809: URL: https://github.com/apache/airflow/pull/34809#issuecomment-1773929085 I've added `full tests needed label adn rebased it -> likely the issues are because only subset of docs was built due to selective checks. With `full tests needed` label, all of them

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] AIP-58: Add Airflow ObjectStore (AFS) [airflow]

2023-10-21 Thread via GitHub
bolkedebruin commented on code in PR #34729: URL: https://github.com/apache/airflow/pull/34729#discussion_r1367798191 ## airflow/io/store/__init__.py: ## Review Comment: Yes I think it will be extended for example with `dataframe` and potentially `catalog`. -- This

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

Re: [I] `FTPSHook.store_file()` change directory [airflow]

2023-10-21 Thread via GitHub
makrushin-evgenii commented on issue #35015: URL: https://github.com/apache/airflow/issues/35015#issuecomment-1773911953 Submit a PR: https://github.com/apache/airflow/pull/35105 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[PR] FTPHook methods should not change working directory [airflow]

2023-10-21 Thread via GitHub
makrushin-evgenii opened a new pull request, #35105: URL: https://github.com/apache/airflow/pull/35105 This methods change current directory. And second call with same directory will raise `no such file or directory` error. So I add `cwd` call to change to origin directory closes:

Re: [PR] AIP-58: Add Airflow ObjectStore (AFS) [airflow]

2023-10-21 Thread via GitHub
bolkedebruin commented on code in PR #34729: URL: https://github.com/apache/airflow/pull/34729#discussion_r1367792359 ## tests/system/providers/common/io/example_file_transfer_local_to_s3.py: ## @@ -0,0 +1,90 @@ +# Licensed to the Apache Software Foundation (ASF) under one +#

Re: [PR] AIP-58: Add Airflow ObjectStore (AFS) [airflow]

2023-10-21 Thread via GitHub
bolkedebruin commented on code in PR #34729: URL: https://github.com/apache/airflow/pull/34729#discussion_r1367792301 ## airflow/providers/common/io/provider.yaml: ## Review Comment: That's okay to me, but don't consider it part of this PR. It's complex as it is. --

Re: [PR] AIP-58: Add Airflow ObjectStore (AFS) [airflow]

2023-10-21 Thread via GitHub
bolkedebruin commented on code in PR #34729: URL: https://github.com/apache/airflow/pull/34729#discussion_r1367792225 ## airflow/io/store/path.py: ## @@ -0,0 +1,680 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See

Re: [PR] AIP-58: Add Airflow ObjectStore (AFS) [airflow]

2023-10-21 Thread via GitHub
bolkedebruin commented on code in PR #34729: URL: https://github.com/apache/airflow/pull/34729#discussion_r1367791852 ## airflow/providers/common/io/operators/file_transfer.py: ## @@ -0,0 +1,82 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one +# or more

Re: [PR] AIP-58: Add Airflow ObjectStore (AFS) [airflow]

2023-10-21 Thread via GitHub
bolkedebruin commented on code in PR #34729: URL: https://github.com/apache/airflow/pull/34729#discussion_r1367791730 ## airflow/io/__init__.py: ## @@ -0,0 +1,90 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the

Re: [I] Status of testing Providers that were prepared on October 18, 2023 [airflow]

2023-10-21 Thread via GitHub
eladkal commented on issue #35030: URL: https://github.com/apache/airflow/issues/35030#issuecomment-1773910368 Thank you everyone. Providers are released I invite everyone to help improve providers for the next release, a list of open issues can be found

Re: [I] Status of testing Providers that were prepared on October 18, 2023 [airflow]

2023-10-21 Thread via GitHub
eladkal closed issue #35030: Status of testing Providers that were prepared on October 18, 2023 URL: https://github.com/apache/airflow/issues/35030 -- 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

[airflow-site] branch add-documentation-2023-10-18 deleted (was 8dbe6f99a3)

2023-10-21 Thread eladkal
This is an automated email from the ASF dual-hosted git repository. eladkal pushed a change to branch add-documentation-2023-10-18 in repository https://gitbox.apache.org/repos/asf/airflow-site.git was 8dbe6f99a3 Add documentation for packages - 2023-10-18 The revisions that were on this

Re: [PR] Add documentation for packages - 2023-10-18 [airflow-site]

2023-10-21 Thread via GitHub
eladkal merged PR #877: URL: https://github.com/apache/airflow-site/pull/877 -- 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:

svn commit: r64654 - /dev/airflow/providers/ /release/airflow/providers/

2023-10-21 Thread eladkal
Author: eladkal Date: Sat Oct 21 19:58:51 2023 New Revision: 64654 Log: Release Airflow Providers on 2023-10-21 Added: release/airflow/providers/apache-airflow-providers-amazon-8.9.0.tar.gz - copied unchanged from r64653,

Re: [PR] Upgrade to Flask Application Builder 4.3.9 [airflow]

2023-10-21 Thread via GitHub
jens-scheffler-bosch commented on PR #35085: URL: https://github.com/apache/airflow/pull/35085#issuecomment-1773898293 2.8.0 is also okay. We have (for our setup) no dependency. No pressure from my side. -- This is an automated message from the Apache Git Service. To respond to the

[airflow] branch main updated: Refactor shorter defaults (#34350)

2023-10-21 Thread eladkal
This is an automated email from the ASF dual-hosted git repository. eladkal pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/airflow.git The following commit(s) were added to refs/heads/main by this push: new 7d80b7d5e4 Refactor shorter defaults (#34350)

Re: [PR] Refactor shorter defaults [airflow]

2023-10-21 Thread via GitHub
eladkal merged PR #34350: URL: https://github.com/apache/airflow/pull/34350 -- 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:

Re: [PR] AIP-58: Add Airflow ObjectStore (AFS) [airflow]

2023-10-21 Thread via GitHub
jens-scheffler-bosch commented on code in PR #34729: URL: https://github.com/apache/airflow/pull/34729#discussion_r1367761520 ## airflow/io/store/__init__.py: ## Review Comment: What is the reason that we have a sub-package `store` below `airflow.io` if there are no other

Re: [PR] Migrate provider-specific executor docs to providers [airflow]

2023-10-21 Thread via GitHub
eladkal commented on PR #34809: URL: https://github.com/apache/airflow/pull/34809#issuecomment-1773892784 > Thanks. What's the best way for me to retry the failed test? Just did. Lets see -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] Migrate provider-specific executor docs to providers [airflow]

2023-10-21 Thread via GitHub
RNHTTR commented on PR #34809: URL: https://github.com/apache/airflow/pull/34809#issuecomment-1773877109 Thanks. What's the best way for me to retry the failed test? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
pierrejeambrun commented on PR #35086: URL: https://github.com/apache/airflow/pull/35086#issuecomment-1773876805 Thank you for the reviews. I agree, both updating the release process and image caching are important and should be done in follow up steps. @potiuk I will address

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

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

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

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

[PR] Expose catalog parameter in `AthenaOpeartor` [airflow]

2023-10-21 Thread via GitHub
eladkal opened a new pull request, #35103: URL: https://github.com/apache/airflow/pull/35103 See https://github.com/apache/airflow/pull/35090#discussion_r1367768708 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

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

Re: [PR] Add k8s recommended labels [airflow]

2023-10-21 Thread via GitHub
Owen-CH-Leung commented on PR #34735: URL: https://github.com/apache/airflow/pull/34735#issuecomment-1773860191 I've applied the fix here to truncate `airflow.fullname` to return at most 40 chars. -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] AIP-58: Add Airflow ObjectStore (AS) [airflow]

2023-10-21 Thread via GitHub
hussein-awala commented on code in PR #34729: URL: https://github.com/apache/airflow/pull/34729#discussion_r1367713729 ## airflow/io/__init__.py: ## @@ -0,0 +1,90 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See

Re: [PR] Refactor shorter defaults [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #34350: URL: https://github.com/apache/airflow/pull/34350#issuecomment-1773847455 Rebased to see if it works with latest main. -- 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

Re: [PR] Migrate provider-specific executor docs to providers [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #34809: URL: https://github.com/apache/airflow/pull/34809#issuecomment-1773846644 Rebased. Let's see if the fix works. -- 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

Re: [PR] Upgrade to Flask Application Builder 4.3.9 [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #35085: URL: https://github.com/apache/airflow/pull/35085#issuecomment-1773846413 Well. Just changed it to 2.8.0. It won't make it to 2.7.3 because we have quite heavy refactor for AIP-58 and we won't be able to cherry-pick this change cleanly. Sorry for that :( --

[airflow] branch main updated: Fix handling selective docs builds for "special" packages (#35102)

2023-10-21 Thread potiuk
This is an automated email from the ASF dual-hosted git repository. potiuk pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/airflow.git The following commit(s) were added to refs/heads/main by this push: new a562174296 Fix handling selective docs builds for

Re: [PR] Fix handling selective docs builds for "special" packages [airflow]

2023-10-21 Thread via GitHub
potiuk merged PR #35102: URL: https://github.com/apache/airflow/pull/35102 -- 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:

Re: [PR] Upgrade to Flask Application Builder 4.3.9 [airflow]

2023-10-21 Thread via GitHub
jens-scheffler-bosch commented on PR #35085: URL: https://github.com/apache/airflow/pull/35085#issuecomment-1773840832 FYI @wolfdn Your fix is going to be integrated in 2.7.3 :-D -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[airflow] branch main updated: Add instructions on how you can debug Breeze easily (#35101)

2023-10-21 Thread potiuk
This is an automated email from the ASF dual-hosted git repository. potiuk pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/airflow.git The following commit(s) were added to refs/heads/main by this push: new 5973c6a217 Add instructions on how you can debug

Re: [PR] Add instructions on how you can debug Breeze easily [airflow]

2023-10-21 Thread via GitHub
potiuk merged PR #35101: URL: https://github.com/apache/airflow/pull/35101 -- 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:

[airflow] branch main updated (dc2e8522bf -> 4198146f49)

2023-10-21 Thread potiuk
This is an automated email from the ASF dual-hosted git repository. potiuk pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/airflow.git from dc2e8522bf Use airflow released in PyPI for k8s test environment (#35099) add 4198146f49 Upgrade to Flask

Re: [PR] Upgrade to Flask Application Builder 4.3.9 [airflow]

2023-10-21 Thread via GitHub
potiuk merged PR #35085: URL: https://github.com/apache/airflow/pull/35085 -- 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:

Re: [PR] Fix handling selective docs builds for "special" packages [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #35102: URL: https://github.com/apache/airflow/pull/35102#issuecomment-1773834304 I found also a duplication @Taragolis @amoghrajesh -> so the docs build params used their own version of converting from short-hand to filters, and I know made them common. -- This

Re: [PR] Fix handling selective docs builds for "special" packages [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35102: URL: https://github.com/apache/airflow/pull/35102#discussion_r1367747958 ## dev/breeze/src/airflow_breeze/params/doc_build_params.py: ## @@ -20,20 +20,30 @@ from dataclasses import dataclass from airflow_breeze.branch_defaults import

Re: [PR] Fix handling selective docs builds for "special" packages [airflow]

2023-10-21 Thread via GitHub
amoghrajesh commented on code in PR #35102: URL: https://github.com/apache/airflow/pull/35102#discussion_r1367747019 ## dev/breeze/src/airflow_breeze/params/doc_build_params.py: ## @@ -20,20 +20,30 @@ from dataclasses import dataclass from airflow_breeze.branch_defaults

Re: [PR] Add instructions on how you can debug Breeze easily [airflow]

2023-10-21 Thread via GitHub
amoghrajesh commented on code in PR #35101: URL: https://github.com/apache/airflow/pull/35101#discussion_r1367746460 ## BREEZE.rst: ## @@ -2649,3 +2649,50 @@ This will also remove breeze from the folder: ``${HOME}.local/bin/`` .. code-block:: bash pipx uninstall

Re: [PR] Migrate provider-specific executor docs to providers [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #34809: URL: https://github.com/apache/airflow/pull/34809#issuecomment-1773825770 https://github.com/apache/airflow/pull/35102 -- 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

[PR] Fix handling selective docs builds for "special" packages [airflow]

2023-10-21 Thread via GitHub
potiuk opened a new pull request, #35102: URL: https://github.com/apache/airflow/pull/35102 The #35069 and #35087 that switched from `--package-filter` to shorthand package names in CI did not handle all the cases - special package names such as "apache-airflow" or "helm-chart" were

Re: [PR] Add instructions on how you can debug Breeze easily [airflow]

2023-10-21 Thread via GitHub
hussein-awala commented on code in PR #35101: URL: https://github.com/apache/airflow/pull/35101#discussion_r1367742062 ## BREEZE.rst: ## @@ -2649,3 +2649,50 @@ This will also remove breeze from the folder: ``${HOME}.local/bin/`` .. code-block:: bash pipx uninstall

Re: [PR] Migrate provider-specific executor docs to providers [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #34809: URL: https://github.com/apache/airflow/pull/34809#issuecomment-1773817679 > Is this just a flaky test? It builds fine locally Likely one more fix to recently completed `docs-build` command for selective docs building - let me see. -- This is an

Re: [PR] Replace numpy example with practical exercise demonstrating top-level code [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #35097: URL: https://github.com/apache/airflow/pull/35097#issuecomment-1773816055 Yeah but it does matter and I think we should explain it to educate the users. Similarly as the user who asked the question about PEP8 conflicting with our advice, they might not

Re: [PR] Migrate provider-specific executor docs to providers [airflow]

2023-10-21 Thread via GitHub
RNHTTR commented on PR #34809: URL: https://github.com/apache/airflow/pull/34809#issuecomment-1773811868 Is this just a flaky test? It builds fine locally -- 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

Re: [PR] Add instructions on how you can debug Breeze easily [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #35101: URL: https://github.com/apache/airflow/pull/35101#issuecomment-1773809275 Since we are going to work on more of changes similar to https://github.com/apache/airflow/pull/35086 I've figured that it might be non-obvious how to easily configure your IDE to run

[PR] Add instructions on how you can debug Breeze easily [airflow]

2023-10-21 Thread via GitHub
potiuk opened a new pull request, #35101: URL: https://github.com/apache/airflow/pull/35101 It could be unclear how to debug Breeze using IDE debuggers, this change provides an explanation including screenshot from PyCharm. --- **^ Add meaningful

Re: [PR] Replace numpy example with practical exercise demonstrating top-level code [airflow]

2023-10-21 Thread via GitHub
RNHTTR commented on PR #35097: URL: https://github.com/apache/airflow/pull/35097#issuecomment-1773804072 I did add this blurb about imports: > Note that import statements also count as top-level code. So, if you have an import statement that takes a long time or the imported module

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35086: URL: https://github.com/apache/airflow/pull/35086#discussion_r1367730805 ## dev/breeze/src/airflow_breeze/commands/sbom_commands.py: ## @@ -291,25 +291,74 @@ def generate_providers_requirements( with

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35086: URL: https://github.com/apache/airflow/pull/35086#discussion_r1367733237 ## dev/breeze/src/airflow_breeze/utils/cdxgen.py: ## @@ -217,28 +231,41 @@ def get_requirements_for_provider( ) -def

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35086: URL: https://github.com/apache/airflow/pull/35086#discussion_r1367733237 ## dev/breeze/src/airflow_breeze/utils/cdxgen.py: ## @@ -217,28 +231,41 @@ def get_requirements_for_provider( ) -def

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35086: URL: https://github.com/apache/airflow/pull/35086#discussion_r1367733237 ## dev/breeze/src/airflow_breeze/utils/cdxgen.py: ## @@ -217,28 +231,41 @@ def get_requirements_for_provider( ) -def

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35086: URL: https://github.com/apache/airflow/pull/35086#discussion_r1367733237 ## dev/breeze/src/airflow_breeze/utils/cdxgen.py: ## @@ -217,28 +231,41 @@ def get_requirements_for_provider( ) -def

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35086: URL: https://github.com/apache/airflow/pull/35086#discussion_r1367730805 ## dev/breeze/src/airflow_breeze/commands/sbom_commands.py: ## @@ -291,25 +291,74 @@ def generate_providers_requirements( with

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35086: URL: https://github.com/apache/airflow/pull/35086#discussion_r1367730404 ## dev/breeze/src/airflow_breeze/commands/sbom_commands.py: ## @@ -291,25 +291,74 @@ def generate_providers_requirements( with

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35086: URL: https://github.com/apache/airflow/pull/35086#discussion_r1367730181 ## dev/breeze/src/airflow_breeze/commands/sbom_commands.py: ## @@ -291,25 +291,74 @@ def generate_providers_requirements( with

Re: [PR] Add task parameter to set custom logger name [airflow]

2023-10-21 Thread via GitHub
Joffreybvn commented on code in PR #34964: URL: https://github.com/apache/airflow/pull/34964#discussion_r1367719098 ## airflow/models/baseoperator.py: ## @@ -1219,14 +1226,10 @@ def __deepcopy__(self, memo): return result def __getstate__(self): -state =

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35086: URL: https://github.com/apache/airflow/pull/35086#discussion_r1367726001 ## dev/breeze/src/airflow_breeze/commands/sbom_commands.py: ## @@ -291,25 +291,74 @@ def generate_providers_requirements( with

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35086: URL: https://github.com/apache/airflow/pull/35086#discussion_r1367725810 ## dev/breeze/src/airflow_breeze/commands/sbom_commands.py: ## @@ -291,25 +291,74 @@ def generate_providers_requirements( with

Re: [PR] Add task parameter to set custom logger name [airflow]

2023-10-21 Thread via GitHub
Joffreybvn commented on code in PR #34964: URL: https://github.com/apache/airflow/pull/34964#discussion_r1367725602 ## airflow/utils/log/logging_mixin.py: ## @@ -68,14 +68,43 @@ class LoggingMixin: """Convenience super-class to have a logger configured with the class

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on code in PR #35086: URL: https://github.com/apache/airflow/pull/35086#discussion_r1367724733 ## dev/breeze/src/airflow_breeze/commands/sbom_commands.py: ## @@ -321,14 +370,14 @@ def generate_providers_requirements( pool.apply_async(

Re: [I] Status of testing Providers that were prepared on October 18, 2023 [airflow]

2023-10-21 Thread via GitHub
123MwanjeMike commented on issue #35030: URL: https://github.com/apache/airflow/issues/35030#issuecomment-1773781269 #34972 works fine -- 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

Re: [PR] Refactor commands to unify daemon context handling [airflow]

2023-10-21 Thread via GitHub
Bisk1 commented on code in PR #34945: URL: https://github.com/apache/airflow/pull/34945#discussion_r1367723811 ## airflow/cli/commands/daemon_utils.py: ## @@ -0,0 +1,89 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements.

Re: [PR] Providers requirements for every python version [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #35086: URL: https://github.com/apache/airflow/pull/35086#issuecomment-1773778101 All looks good I have just a few general comments (and some improvement proposals / test results will come as inline comments). 1. We will need this "all-airflow" images only

Re: [PR] Add task parameter to set custom logger name [airflow]

2023-10-21 Thread via GitHub
Joffreybvn commented on code in PR #34964: URL: https://github.com/apache/airflow/pull/34964#discussion_r1367719098 ## airflow/models/baseoperator.py: ## @@ -1219,14 +1226,10 @@ def __deepcopy__(self, memo): return result def __getstate__(self): -state =

Re: [PR] Add task parameter to set custom logger name [airflow]

2023-10-21 Thread via GitHub
Joffreybvn commented on code in PR #34964: URL: https://github.com/apache/airflow/pull/34964#discussion_r1367719098 ## airflow/models/baseoperator.py: ## @@ -1219,14 +1226,10 @@ def __deepcopy__(self, memo): return result def __getstate__(self): -state =

[airflow] branch main updated: Use airflow released in PyPI for k8s test environment (#35099)

2023-10-21 Thread bolke
This is an automated email from the ASF dual-hosted git repository. bolke pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/airflow.git The following commit(s) were added to refs/heads/main by this push: new dc2e8522bf Use airflow released in PyPI for k8s

Re: [PR] Use airflow released in PyPI for k8s test environment [airflow]

2023-10-21 Thread via GitHub
bolkedebruin merged PR #35099: URL: https://github.com/apache/airflow/pull/35099 -- 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:

[PR] Use airflow released in PyPI for k8s test environment [airflow]

2023-10-21 Thread via GitHub
potiuk opened a new pull request, #35099: URL: https://github.com/apache/airflow/pull/35099 So far we've been using ".[cncf.kubernetes]" as requirement for creating kubernetes test virtualenve (in k8s_requirements.txt). This becomes problematic when we add a new pre-installed

Re: [PR] Replace numpy example with practical exercise demonstrating top-level code [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #35097: URL: https://github.com/apache/airflow/pull/35097#issuecomment-1773764486 One thing worth mentioning that even 0.3 s is pretty impactful. All our DAGs are parsed in DAG file process in a separately forked processes - so if such 'pandas' import happens at top

Re: [PR] Refactor commands to unify daemon context handling [airflow]

2023-10-21 Thread via GitHub
Taragolis commented on code in PR #34945: URL: https://github.com/apache/airflow/pull/34945#discussion_r1367714633 ## airflow/cli/commands/daemon_utils.py: ## @@ -0,0 +1,89 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license

Re: [PR] Replace numpy example with practical exercise demonstrating top-level code [airflow]

2023-10-21 Thread via GitHub
potiuk commented on PR #35097: URL: https://github.com/apache/airflow/pull/35097#issuecomment-1773761513 I like the idea of mentioning and being explicit about expensive APIs but I think there is a value in mentioning the imports, because not many people are aware how big of an impact

Re: [I] BigQueryValueCheckOperator does not accept non-default project_id, which lead to jobs with impersonation_chain to fail. [airflow]

2023-10-21 Thread via GitHub
vchiapaikeo commented on issue #32870: URL: https://github.com/apache/airflow/issues/32870#issuecomment-1773745424 @GaryLiuTelus , I know this is a bit old for you now but did you try changing the gcp_conn_id to one that defaults to `project_B` by any chance? That should allow the BQ query

Re: [I] Conditional Task Skip option [airflow]

2023-10-21 Thread via GitHub
eladkal closed issue #35089: Conditional Task Skip option URL: https://github.com/apache/airflow/issues/35089 -- 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,

[airflow] branch main updated: Add `use_krb5ccache` option to `SparkSubmitHook` (#34386)

2023-10-21 Thread eladkal
This is an automated email from the ASF dual-hosted git repository. eladkal pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/airflow.git The following commit(s) were added to refs/heads/main by this push: new 645d52f129 Add `use_krb5ccache` option to

Re: [PR] Add use_krb5ccache option to SparkSubmitHook [airflow]

2023-10-21 Thread via GitHub
eladkal merged PR #34386: URL: https://github.com/apache/airflow/pull/34386 -- 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:

Re: [I] SparkSubmitHook Kerberos ccache support [airflow]

2023-10-21 Thread via GitHub
eladkal closed issue #11246: SparkSubmitHook Kerberos ccache support URL: https://github.com/apache/airflow/issues/11246 -- 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

Re: [PR] Prevent assignment of non JSON serializable values to DagRun.conf dict [airflow]

2023-10-21 Thread via GitHub
eladkal commented on PR #35096: URL: https://github.com/apache/airflow/pull/35096#issuecomment-1773721000 > Can you please add a unit test for the new code which validates a positive and negative case as well? yes unit test is required here -- This is an automated message from the

  1   2   >