syedahsn commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232941301
##
airflow/providers/amazon/aws/operators/eks.py:
##
@@ -184,12 +238,12 @@ def execute(self, context: Context):
)
)
-
potiuk commented on issue #31972:
URL: https://github.com/apache/airflow/issues/31972#issuecomment-1595559666
The way it looks - it's a problem of your Database. You likely try to use
some active-active DB (not standard Postgres, but something that builds on top
of Postgres).
Likely
github-actions[bot] closed pull request #30892: Fix depends_on_past work for
Dynamic tasks
URL: https://github.com/apache/airflow/pull/30892
--
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 speci
o-nikolas commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232881332
##
airflow/providers/amazon/aws/operators/eks.py:
##
@@ -184,12 +238,12 @@ def execute(self, context: Context):
)
)
-
ksundeepsatya closed issue #31908: execution_date backward compatibility
between Airflow1 and Airflow2
URL: https://github.com/apache/airflow/issues/31908
--
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 g
ksundeepsatya commented on issue #31908:
URL: https://github.com/apache/airflow/issues/31908#issuecomment-1595413134
I would like to apologize the community here. Looks like internally we have
forked Airflow1 to modify the behavior of execution date in Airflow1 to set
execution to end time
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 41fb9b4c49 Deprecate `wait_for_completion` from
`
eladkal merged PR #31884:
URL: https://github.com/apache/airflow/pull/31884
--
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...@airflow.
eladkal commented on code in PR #31884:
URL: https://github.com/apache/airflow/pull/31884#discussion_r1232857696
##
airflow/providers/amazon/aws/operators/ecs.py:
##
@@ -202,53 +202,39 @@ class
EcsDeregisterTaskDefinitionOperator(EcsBaseOperator):
:param task_definition:
ginwakeup commented on issue #31972:
URL: https://github.com/apache/airflow/issues/31972#issuecomment-1595377593
Same with scheduler:
```
[2023-06-16T22:14:40.368+] {scheduler_job.py:776} ERROR - Exception when
executing SchedulerJob._run_scheduler_loop
Traceback (most recen
ginwakeup commented on issue #31972:
URL: https://github.com/apache/airflow/issues/31972#issuecomment-1595371826
Triggerer exception as soon as it starts:
```
[2023-06-16T22:08:22.757+] {triggerer_job.py:108} ERROR - Exception when
executing TriggererJob._run_trigger_loop
Traceb
syedahsn commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232833537
##
airflow/providers/amazon/aws/operators/eks.py:
##
@@ -184,12 +235,12 @@ def execute(self, context: Context):
)
)
-
ginwakeup commented on issue #31972:
URL: https://github.com/apache/airflow/issues/31972#issuecomment-1595366827
@jens-scheffler-bosch forgive me, that's not the scheduler logs, it's the
triggerer.
The scheduler errors like this:
```
[2023-06-16T22:01:08.483+] {settings.
ginwakeup commented on issue #31972:
URL: https://github.com/apache/airflow/issues/31972#issuecomment-1595355293
I've also just tried to run `airflow db reset` but it didn't help.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
ginwakeup commented on issue #31972:
URL: https://github.com/apache/airflow/issues/31972#issuecomment-1595354267
@jens-scheffler-bosch More details on the setup:
- gitSync pulls DAGS and it runs on a separate pod which mounts a PVC
- The PVC is mounted on all the airflow components
-
jens-scheffler-bosch commented on issue #31972:
URL: https://github.com/apache/airflow/issues/31972#issuecomment-1595351825
Can you please add some details which Airflow version you are actually
using? Else it is a bit shooting in the dark, what the problem might be.
Taking a look to
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 7fc2caf69c Updating con
jens-scheffler-bosch closed issue #31930: UI: New trigger DAG with config form
doesn’t allow valid floats and empty strings
URL: https://github.com/apache/airflow/issues/31930
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
jens-scheffler-bosch commented on issue #31930:
URL: https://github.com/apache/airflow/issues/31930#issuecomment-1595349319
Thanks for reporting this bug - and as Part 1 is already fixed with a PR let
me answer on the others.
Regarding Part 2) Empty strings are converted to `null` val
ginwakeup opened a new issue, #31972:
URL: https://github.com/apache/airflow/issues/31972
### Apache Airflow version
Other Airflow 2 version (please specify below)
### What happened
Airflow keeps polluting the postgres DB. I cannot understand what causes
this but it happ
killua1zoldyck commented on PR #31837:
URL: https://github.com/apache/airflow/pull/31837#issuecomment-1595336279
> > I have updated the changes from #31824 @o-nikolas
>
> Thanks! Unfortunately there are some more conflicts due to some more
logging PRs being merged
I have update
dstandish commented on code in PR #30271:
URL: https://github.com/apache/airflow/pull/30271#discussion_r1232796844
##
airflow/models/abstractoperator.py:
##
@@ -188,6 +188,33 @@ def get_flat_relatives(self, upstream: bool = False) ->
Collection[Operator]:
return se
jhbigler commented on PR #31950:
URL: https://github.com/apache/airflow/pull/31950#issuecomment-1595324301
I have implemented the suggested changes, open to additional feedback
(@phanikumv @uranusjr @utkarsharma2)
--
This is an automated message from the Apache Git Service.
To respond to
jens-scheffler-bosch opened a new pull request, #31971:
URL: https://github.com/apache/airflow/pull/31971
This PR is for branch 2.6 releases only. It is already fixed on main/2.7.0++
Not more details on this PR, it is a one-liner, details in the bug ticket
closes: #31869
-
This is an automated email from the ASF dual-hosted git repository.
dstandish 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 b459af3ee0 Replace State usages with strong-type
shahar1 opened a new pull request, #31970:
URL: https://github.com/apache/airflow/pull/31970
Following discussion #31714 - I'm trying to remove `airflow` user from
`Dockerfile.ci` and see how it affects it.
---
**^ Add meaningful description above**
Read the **[Pull
vincbeck commented on code in PR #31939:
URL: https://github.com/apache/airflow/pull/31939#discussion_r1232681082
##
airflow/providers/amazon/aws/hooks/chime.py:
##
@@ -0,0 +1,113 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license
vincbeck commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232670101
##
airflow/providers/amazon/aws/operators/eks.py:
##
@@ -59,7 +59,54 @@
FARGATE_FULL_NAME = "AWS Fargate profiles"
-class EksCreateClusterOperator(BaseOperator)
fgalind1 commented on PR #31066:
URL: https://github.com/apache/airflow/pull/31066#issuecomment-1595202690
airflow folks sorry to bother again, but wonder if this PR could get any
traction 😃
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
Gollum999 opened a new issue, #31969:
URL: https://github.com/apache/airflow/issues/31969
### Apache Airflow version
2.6.1
### What happened
A number of Airflow CLI commands will fail with an error like the one below
if a DAG uses a [custom
Timetable](https://airflow.ap
potiuk commented on issue #31968:
URL: https://github.com/apache/airflow/issues/31968#issuecomment-1595189119
Surely. Constraints of airflow do not include pandas extra. As explained in
our documentation, when you want to install/upgrede providers independently
from the airflow core, you sh
o-nikolas commented on PR #31837:
URL: https://github.com/apache/airflow/pull/31837#issuecomment-1595186649
> I have updated the changes from #31824 @o-nikolas
Thanks! Unfortunately there are some more conflicts due to some more logging
PRs being merged
--
This is an automated mess
This is an automated email from the ASF dual-hosted git repository.
onikolas 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 e0f21f43c6 Various fixes on ECS run task operator
o-nikolas merged PR #31838:
URL: https://github.com/apache/airflow/pull/31838
--
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...@airflo
o-nikolas commented on code in PR #31838:
URL: https://github.com/apache/airflow/pull/31838#discussion_r1232645548
##
airflow/providers/amazon/aws/operators/ecs.py:
##
@@ -506,25 +515,24 @@ def execute(self, context, session=None):
@AwsBaseHook.retry(should_retry_eni)
jhbigler commented on code in PR #31950:
URL: https://github.com/apache/airflow/pull/31950#discussion_r1232642277
##
airflow/providers/trino/hooks/trino.py:
##
@@ -95,7 +95,12 @@ def get_conn(self) -> Connection:
elif db.password:
auth = trino.auth.BasicAut
dstandish closed pull request #31921: Simplify get_flat_relative_ids logic
URL: https://github.com/apache/airflow/pull/31921
--
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
shahar1 commented on code in PR #31885:
URL: https://github.com/apache/airflow/pull/31885#discussion_r1232625943
##
airflow/providers/google/suite/transfers/gcs_to_gdrive.py:
##
@@ -63,12 +63,15 @@ class GCSToGoogleDriveOperator(BaseOperator):
For example, with prefix `
dstandish commented on code in PR #31927:
URL: https://github.com/apache/airflow/pull/31927#discussion_r1232629952
##
airflow/models/baseoperator.py:
##
@@ -1838,6 +1839,38 @@ def cross_downstream(
task.set_downstream(to_tasks)
+def chain_sequential(*elements: Depen
shahar1 commented on code in PR #31885:
URL: https://github.com/apache/airflow/pull/31885#discussion_r1232625943
##
airflow/providers/google/suite/transfers/gcs_to_gdrive.py:
##
@@ -63,12 +63,15 @@ class GCSToGoogleDriveOperator(BaseOperator):
For example, with prefix `
This is an automated email from the ASF dual-hosted git repository.
husseinawala 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 e22ce9baed Fix masking nested variable fields
hussein-awala closed issue #31873: KubernetesPodOperator doesn't mask variables
in Rendered Template that are used as arguments
URL: https://github.com/apache/airflow/issues/31873
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
hussein-awala merged PR #31964:
URL: https://github.com/apache/airflow/pull/31964
--
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...@ai
cbuffett opened a new issue, #31968:
URL: https://github.com/apache/airflow/issues/31968
### Apache Airflow version
2.6.1
### What happened
The 2.6.1-python3.7 constraints specify `pyarrow==9.0.0` and
`snowflake-connector-python=3.0.3`. However, version 3.0.0 of
`snowf
o-nikolas commented on code in PR #31942:
URL: https://github.com/apache/airflow/pull/31942#discussion_r1232600792
##
airflow/providers/amazon/aws/hooks/athena.py:
##
@@ -229,51 +242,33 @@ def get_query_results_paginator(
return paginator.paginate(**result_params)
This is an automated email from the ASF dual-hosted git repository.
dstandish 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 fc0e5a4d42 Upgrade ruff to 0.272 (#31966)
fc0e5a
dstandish merged PR #31966:
URL: https://github.com/apache/airflow/pull/31966
--
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...@airflo
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 3003b16998 Fixed failing main on too fast merged ch
potiuk merged PR #31967:
URL: https://github.com/apache/airflow/pull/31967
--
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...@airflow.a
potiuk opened a new pull request, #31967:
URL: https://github.com/apache/airflow/pull/31967
Merged #31961 - as a typo one-letter-fix thinking that - well it can't
possibly cause any problems.
Boy, how was I wrong.
---
**^ Add meaningful description above**
Rea
o-nikolas commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232574760
##
airflow/providers/amazon/aws/triggers/eks.py:
##
@@ -33,49 +33,52 @@ class EksCreateFargateProfileTrigger(BaseTrigger):
:param cluster_name: The name of t
uranusjr commented on PR #31731:
URL: https://github.com/apache/airflow/pull/31731#issuecomment-1595061846
FWIW we really should switch away from sphinx-autoapi as well (in favor of
`sphinx.ext.autodoc`), I think that’s another blocker for Sphinx 7 and
generally a pain to interact with.
-
o-nikolas commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232571656
##
airflow/providers/amazon/aws/operators/eks.py:
##
@@ -393,51 +416,41 @@ def __init__(
) -> None:
self.cluster_name = cluster_name
self.pod
syedahsn commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232568930
##
airflow/providers/amazon/aws/triggers/eks.py:
##
@@ -33,49 +33,52 @@ class EksCreateFargateProfileTrigger(BaseTrigger):
:param cluster_name: The name of th
syedahsn commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232567156
##
airflow/providers/amazon/aws/operators/eks.py:
##
@@ -393,51 +416,41 @@ def __init__(
) -> None:
self.cluster_name = cluster_name
self.pod_
syedahsn commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232565571
##
airflow/providers/amazon/aws/operators/eks.py:
##
@@ -184,12 +235,12 @@ def execute(self, context: Context):
)
)
-
syedahsn commented on code in PR #31712:
URL: https://github.com/apache/airflow/pull/31712#discussion_r1232564403
##
airflow/providers/amazon/aws/hooks/base_aws.py:
##
@@ -820,7 +826,7 @@ def get_waiter(
self,
waiter_name: str,
parameters: dict[str, st
o-nikolas commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232558015
##
airflow/providers/amazon/aws/operators/eks.py:
##
@@ -184,12 +235,12 @@ def execute(self, context: Context):
)
)
-
syedahsn commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232545410
##
airflow/providers/amazon/aws/operators/eks.py:
##
@@ -59,7 +59,54 @@
FARGATE_FULL_NAME = "AWS Fargate profiles"
-class EksCreateClusterOperator(BaseOperator)
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 578cbb24fb Skip python version check in some pre-co
potiuk merged PR #31965:
URL: https://github.com/apache/airflow/pull/31965
--
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...@airflow.a
potiuk opened a new pull request, #31965:
URL: https://github.com/apache/airflow/pull/31965
Some providers are excluded for some versions of Python (for example the
`apache.hive` provider is excluded on Python 3.11. However this might make some
pre-commits confused when running on Python 3.
phanikumv commented on PR #31925:
URL: https://github.com/apache/airflow/pull/31925#issuecomment-1594949515
> @phanikumv I fixed tests, could you please check this PR one more time?
whats the use case behind this change? What problem were you facing
--
This is an automated message f
phanikumv commented on PR #31925:
URL: https://github.com/apache/airflow/pull/31925#issuecomment-1594949521
> @phanikumv I fixed tests, could you please check this PR one more time?
whats the use case behind this change? What problem were you facing
--
This is an automated message f
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 f03f73100e Fix typo in scheduler error (#31961)
f03
potiuk merged PR #31961:
URL: https://github.com/apache/airflow/pull/31961
--
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...@airflow.a
potiuk commented on issue #31873:
URL: https://github.com/apache/airflow/issues/31873#issuecomment-1594934440
> @potiuk @phanikumv I think we should mask the value of the loaded dict
when `deserialize_json=True`, I tested #31964 and it fixed the problem
cool!
--
This is an automate
hussein-awala commented on issue #31873:
URL: https://github.com/apache/airflow/issues/31873#issuecomment-1594915719
@potiuk @phanikumv I think we should mask the value of the loaded dict when
`deserialize_json=True`, I tested #31964 and it fixed the problem
--
This is an automated messag
hussein-awala opened a new pull request, #31964:
URL: https://github.com/apache/airflow/pull/31964
closes: #31873
---
**^ Add meaningful description above**
Read the **[Pull Request
Guidelines](https://github.com/apache/airflow/blob/main/CONTRIBUTING.rst#pull-request-gui
vandonr-amz commented on code in PR #31838:
URL: https://github.com/apache/airflow/pull/31838#discussion_r1232431989
##
tests/system/providers/amazon/aws/example_ecs.py:
##
@@ -85,6 +93,7 @@ def get_region():
asg_name = f"{env_id}-asg"
aws_region = get_region()
+
phanikumv commented on code in PR #31960:
URL: https://github.com/apache/airflow/pull/31960#discussion_r1232429182
##
airflow/providers/amazon/aws/operators/eks.py:
##
@@ -59,7 +59,54 @@
FARGATE_FULL_NAME = "AWS Fargate profiles"
-class EksCreateClusterOperator(BaseOperator
phanikumv commented on PR #31951:
URL: https://github.com/apache/airflow/pull/31951#issuecomment-1594900515
> > can you please mention the context of why we are doing this(in the
description), is it because the last time RC packaging wasn't correct ?
>
> We usually place little contex
jedcunningham commented on code in PR #31951:
URL: https://github.com/apache/airflow/pull/31951#discussion_r1232406266
##
dev/README_RELEASE_AIRFLOW.md:
##
@@ -583,15 +583,14 @@ Check if sources are the same as in the tag:
```bash
cd X.Y.Zrc1
tar -xvzf *-source.tar.gz
-pushd
jedcunningham commented on code in PR #31951:
URL: https://github.com/apache/airflow/pull/31951#discussion_r1232405802
##
dev/README_RELEASE_AIRFLOW.md:
##
@@ -583,15 +583,14 @@ Check if sources are the same as in the tag:
```bash
cd X.Y.Zrc1
tar -xvzf *-source.tar.gz
-pushd
vincbeck commented on code in PR #31939:
URL: https://github.com/apache/airflow/pull/31939#discussion_r1232392626
##
airflow/providers/amazon/aws/hooks/chime.py:
##
@@ -0,0 +1,104 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license
potiuk commented on issue #31873:
URL: https://github.com/apache/airflow/issues/31873#issuecomment-1594867356
> Hi @phanikumv , thank you for your comment.
>
> I tried to implement the use of masking the secret on DAG level, but that
still doesn't work:
>
> ```
> @task
>
vincbeck commented on code in PR #31942:
URL: https://github.com/apache/airflow/pull/31942#discussion_r1232381091
##
airflow/providers/amazon/aws/hooks/athena.py:
##
@@ -38,8 +41,7 @@ class AthenaHook(AwsBaseHook):
Provide thick wrapper around
:external+boto3:py:class:
potiuk opened a new issue, #31963:
URL: https://github.com/apache/airflow/issues/31963
### Body
We should upgrade Sphinx to version 7
Sphinx 6 has known issues with informing about various errors in our
documentation and it becomes REALLY painful. Quite often contributors are
MaksYermak commented on PR #31925:
URL: https://github.com/apache/airflow/pull/31925#issuecomment-1594817462
@phanikumv I fixed tests, could you please check this PR one more time?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
Gollum999 commented on issue #31945:
URL: https://github.com/apache/airflow/issues/31945#issuecomment-1594804866
Just confirmed that this reproduces on 2.6.1 as well.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
ephraimbuddy commented on code in PR #31134:
URL: https://github.com/apache/airflow/pull/31134#discussion_r1232336950
##
tests/providers/microsoft/azure/operators/test_azure_functions.py:
##
@@ -0,0 +1,52 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or mor
vincbeck commented on code in PR #31838:
URL: https://github.com/apache/airflow/pull/31838#discussion_r1232316815
##
tests/system/providers/amazon/aws/example_ecs.py:
##
@@ -85,6 +93,7 @@ def get_region():
asg_name = f"{env_id}-asg"
aws_region = get_region()
+log
jherrmannNetfonds commented on PR #31798:
URL: https://github.com/apache/airflow/pull/31798#issuecomment-1594756521
thx for reopening.
@blcksrx fyi
I am testing my local version from line 123 with
```
try:
self.log.info(line)
except HTTPError as e:
self.log.warn(e
boring-cyborg[bot] commented on PR #31961:
URL: https://github.com/apache/airflow/pull/31961#issuecomment-1594694209
Congratulations on your first Pull Request and welcome to the Apache Airflow
community! If you have any issues or are unsure about any anything please check
our Contribution
getaaron opened a new pull request, #31961:
URL: https://github.com/apache/airflow/pull/31961
An error message uses “its” (possessive pronoun) when it means “it’s”
(contraction of “it is”. This pull request resolves the issue by inserting an
apostrophe between the second and third chara
NikitasB commented on issue #31873:
URL: https://github.com/apache/airflow/issues/31873#issuecomment-1594678732
Sorry, I closed this by accident. I'm still curious on a solution because if
the token can't be masked, I can't deploy the DAG to production.
--
This is an automated message fr
ephraimbuddy commented on PR #31772:
URL: https://github.com/apache/airflow/pull/31772#issuecomment-1594663021
What do you think about this latest commit:
https://github.com/apache/airflow/pull/31772/commits/cad7874e6e36df2e426d9ab5a8909e780e595d10
--
This is an automated message from the
potiuk commented on code in PR #31731:
URL: https://github.com/apache/airflow/pull/31731#discussion_r1232237312
##
airflow/providers/google/cloud/hooks/bigquery.py:
##
@@ -1716,10 +1690,10 @@ def run_load(
by one or more columns. BigQuery supports clustering for bot
potiuk commented on code in PR #31731:
URL: https://github.com/apache/airflow/pull/31731#discussion_r1232236952
##
airflow/providers/google/cloud/hooks/bigquery.py:
##
@@ -618,10 +610,10 @@ def create_external_table(
:param labels: A dictionary containing labels for the
serrovsky commented on code in PR #31955:
URL: https://github.com/apache/airflow/pull/31955#discussion_r1232235026
##
scripts/docker/clean-logs.sh:
##
@@ -21,19 +21,30 @@ set -euo pipefail
readonly DIRECTORY="${AIRFLOW_HOME:-/usr/local/airflow}"
readonly RETENTION="${AIRFLOW
potiuk commented on PR #31798:
URL: https://github.com/apache/airflow/pull/31798#issuecomment-1594625593
Sorry, Sorry, it was **PURELY** accidental :). I usually write briefly why I
am closing stuff (sometimes maybe in a harsh way but I usually tell why ;)
--
This is an automated message
jherrmannNetfonds commented on PR #31798:
URL: https://github.com/apache/airflow/pull/31798#issuecomment-1594608832
Please consider reopening the PR, since 2.6.x came with braking changes for
the `SparkKubernetesOperator` compared to 2.5.x which would be "fixed" in this
PR. With 2.6.x the `
blcksrx commented on PR #31798:
URL: https://github.com/apache/airflow/pull/31798#issuecomment-1594577291
@potiuk Why closing PR?
With a try catch it would be done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
potiuk commented on PR #31798:
URL: https://github.com/apache/airflow/pull/31798#issuecomment-1594573389
> > > @jherrmannNetfonds Good catch buddy. Since with `watch=True` this
operator is responsible for the execution, logs and states of the task, I
believe in that case the pod/job should
potiuk closed pull request #31798: fix spark-kubernetes-operator compatibility
URL: https://github.com/apache/airflow/pull/31798
--
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.
syedahsn opened a new pull request, #31960:
URL: https://github.com/apache/airflow/pull/31960
The `EksCreateClusterOperator` is capable of capable of creating a Fargate
Profile or Nodegroup that is associated with the newly created cluster. The
code for creating the Fargate Profile and Node
potiuk commented on PR #31798:
URL: https://github.com/apache/airflow/pull/31798#issuecomment-1594572974
> > @jherrmannNetfonds Good catch buddy. Since with `watch=True` this
operator is responsible for the execution, logs and states of the task, I
believe in that case the pod/job should be
raphaelauv opened a new pull request, #31959:
URL: https://github.com/apache/airflow/pull/31959
(no comment)
--
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,
potiuk commented on issue #31957:
URL: https://github.com/apache/airflow/issues/31957#issuecomment-1594564595
Feel free to add those metrics. Assigned you. Note that we already have
"open-telemetry" added in Airlfow `main` and it's being worked on and improved,
so you might want to cc: @fer
ephraimbuddy commented on code in PR #31772:
URL: https://github.com/apache/airflow/pull/31772#discussion_r1232107795
##
airflow/models/dag.py:
##
@@ -3518,7 +3541,7 @@ def deactivate_deleted_dags(cls, alive_dag_filelocs:
list[str], session=NEW_SESS
"""
log.de
1 - 100 of 179 matches
Mail list logo
