vioao opened a new pull request, #32795:
URL: https://github.com/apache/airflow/pull/32795
---
**^ Add meaningful description above**
Read the **[Pull Request
Guidelines](https://github.com/apache/airflow/blob/main/CONTRIBUTING.rst#pull-request-guidelines)**
for mo
boring-cyborg[bot] commented on PR #32795:
URL: https://github.com/apache/airflow/pull/32795#issuecomment-1647353312
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
dzhigimont commented on PR #32701:
URL: https://github.com/apache/airflow/pull/32701#issuecomment-1647371922
> Why are the upstream tasks calculated incorrectly before the task is
expanded? Task expansion happens on the task, why would it affect the upstream
tasks?
Apologies
moiseenkov opened a new pull request, #32796:
URL: https://github.com/apache/airflow/pull/32796
Add system test and docs for DataprocSubmitJobOperator (Trino job)
Related issues: https://github.com/apache/airflow/issues/32407,
https://github.com/apache/airflow/issues/22430,
https://g
bkossakowska opened a new pull request, #32797:
URL: https://github.com/apache/airflow/pull/32797
Fix CloudFirestoreExportDatabaseOperator system test
---
**^ Add meaningful description above**
Read the **[Pull Request
Guidelines](https://github.com/apache/ai
bkossakowska closed pull request #32797: Fix
CloudFirestoreExportDatabaseOperator system test
URL: https://github.com/apache/airflow/pull/32797
--
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 sp
moiseenkov opened a new pull request, #32798:
URL: https://github.com/apache/airflow/pull/32798
Add system test and docs for DataprocSubmitJobOperator (Presto job)
Related issues: https://github.com/apache/airflow/issues/32407,
https://github.com/apache/airflow/issues/22430,
https://
bbovenzi commented on code in PR #31806:
URL: https://github.com/apache/airflow/pull/31806#discussion_r1271930553
##
airflow/www/static/js/dag/details/index.tsx:
##
@@ -134,6 +153,12 @@ const Details = ({ openGroupIds, onToggleGroups,
hoveredTaskState }: Props) => {
[setSe
pateash commented on code in PR #32795:
URL: https://github.com/apache/airflow/pull/32795#discussion_r1271933402
##
airflow/providers/apache/druid/hooks/druid.py:
##
@@ -96,14 +98,20 @@ def submit_indexing_job(self, json_index_spec: dict[str,
Any] | str) -> None:
req
pateash commented on code in PR #32795:
URL: https://github.com/apache/airflow/pull/32795#discussion_r1271931468
##
airflow/providers/apache/druid/hooks/druid.py:
##
@@ -96,14 +98,20 @@ def submit_indexing_job(self, json_index_spec: dict[str,
Any] | str) -> None:
req
bbovenzi commented on PR #31806:
URL: https://github.com/apache/airflow/pull/31806#issuecomment-1647490534
> Looks great! Tested locally and seems nice. 🎉
>
> I just have issues scrolling the gantt. (scroll bars are not working for
me), also I have vertical scroll when there is plenty
Lee-W commented on code in PR #32786:
URL: https://github.com/apache/airflow/pull/32786#discussion_r1271939625
##
airflow/providers/tabular/provider.yaml:
##
@@ -31,6 +31,7 @@ versions:
dependencies:
- apache-airflow>=2.4.0
+ - pyiceberg==0.4.0
Review Comment:
Wonderi
vioao commented on PR #32795:
URL: https://github.com/apache/airflow/pull/32795#issuecomment-1647498017
> As they're using different endpoints, I wonder whether we should create a
new hook and operator instead of overriding the parameter.
@Lee-W
I am not sure about this. But I th
Lee-W commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1271951686
##
airflow/providers/amazon/aws/hooks/redshift_data.py:
##
@@ -53,6 +53,7 @@ def execute_query(
database: str,
sql: str | list[str],
cluster_
bbovenzi commented on code in PR #32350:
URL: https://github.com/apache/airflow/pull/32350#discussion_r1271975386
##
airflow/www/views.py:
##
@@ -2293,15 +2300,17 @@ def clear(self, *, session: Session = NEW_SESSION):
# Lock the related dag runs to prevent from po
almost-online opened a new pull request, #89:
URL: https://github.com/apache/airflow-client-python/pull/89
Apache Airflow Version:
[v2.6.3](https://pypi.python.org/pypi/apache-airflow/2.6.3)
Fixing a `trigger` and a `triggerer_job` properties as nullable
--
This is an autom
pepijngriffioen commented on issue #30883:
URL: https://github.com/apache/airflow/issues/30883#issuecomment-1647558256
Thanks for picking up this fix. Unfortunately we are experiencing the same
problem in airflow 2.6.3, with expanding a taskgroup that contains a branch
operator. I am not re
ivica-k commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272000469
##
airflow/providers/amazon/aws/hooks/redshift_data.py:
##
@@ -53,6 +53,7 @@ def execute_query(
database: str,
sql: str | list[str],
cluste
uranusjr commented on PR #32798:
URL: https://github.com/apache/airflow/pull/32798#issuecomment-1647579649
Can you amend and force-push to fix the typoe in the commit message?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
uranusjr commented on code in PR #32781:
URL: https://github.com/apache/airflow/pull/32781#discussion_r1272016495
##
tests/utils/test_serve_logs.py:
##
@@ -22,7 +22,9 @@
import jwt
import pytest
import time_machine
+from py import path
Review Comment:
Please use `tmp_path
Lee-W commented on PR #32795:
URL: https://github.com/apache/airflow/pull/32795#issuecomment-1647591195
@vioao Or maybe we can make the new hook a subclass of the original one?
WDYT?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
Lee-W commented on code in PR #32779:
URL: https://github.com/apache/airflow/pull/32779#discussion_r1272026282
##
airflow/providers/microsoft/azure/log/wasb_task_handler.py:
##
@@ -148,7 +146,7 @@ def _read_remote_logs(self, ti, try_number, metadata=None)
-> tuple[list[str], l
monik-a opened a new issue, #32799:
URL: https://github.com/apache/airflow/issues/32799
### Apache Airflow version
Other Airflow 2 version (please specify below)
### What happened
We’e refreshing Tableau dashboards with Airflow and the below set of actions
creates issues
Adaverse commented on code in PR #32779:
URL: https://github.com/apache/airflow/pull/32779#discussion_r1272050947
##
airflow/providers/microsoft/azure/log/wasb_task_handler.py:
##
@@ -148,7 +146,7 @@ def _read_remote_logs(self, ti, try_number, metadata=None)
-> tuple[list[str],
vioao commented on PR #32795:
URL: https://github.com/apache/airflow/pull/32795#issuecomment-1647638560
@Lee-W I thought about it.
But it also needs to change the current `DruidOperator` or add a new one. At
the same time, the current `DruidHook` also needs to be reformed(eg. extract
th
amir-brightdata opened a new issue, #32800:
URL: https://github.com/apache/airflow/issues/32800
### Apache Airflow version
Other Airflow 2 version (please specify below)
### What happened
Every time i try to press the download button in a specific task log page,
the enti
Adaverse commented on code in PR #32779:
URL: https://github.com/apache/airflow/pull/32779#discussion_r1272050947
##
airflow/providers/microsoft/azure/log/wasb_task_handler.py:
##
@@ -148,7 +146,7 @@ def _read_remote_logs(self, ti, try_number, metadata=None)
-> tuple[list[str],
pankajastro commented on PR #32000:
URL: https://github.com/apache/airflow/pull/32000#issuecomment-1647650586
> I think we need a test for this
Hi @uranusjr I can see some tests for dag test feature
https://github.com/apache/airflow/blob/main/tests/models/test_dag.py#L1891-L1985
but
This is an automated email from the ASF dual-hosted git repository.
mobuchowski pushed a change to branch load-plugins-from-providers
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit b78c4ceca8 plugins: load plugins from providers
add 8b7ae76026 Fixup docs and optimize
This is an automated email from the ASF dual-hosted git repository.
mobuchowski pushed a commit to branch load-plugins-from-providers
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit e6bd5213ec80bb5fc39b21986a6a67a9c233ade1
Author: Maciej Obuchowski
AuthorDate: Tue Jun 27 14:
uranusjr commented on PR #32701:
URL: https://github.com/apache/airflow/pull/32701#issuecomment-1647662076
Thanks for the very detailed explanation, that makes sense now! I think the
fix is on the right track, but not at the right place. We have a separate dep
that checks for this scenario
ephraimbuddy opened a new pull request, #32801:
URL: https://github.com/apache/airflow/pull/32801
There was a mistake in refactoring this query but the code had no test
coverage. This commit fixes it and adds a test to cover this part of the code
--
This is an automated message fr
phanikumv commented on code in PR #32350:
URL: https://github.com/apache/airflow/pull/32350#discussion_r1272102429
##
airflow/www/views.py:
##
@@ -2293,15 +2300,17 @@ def clear(self, *, session: Session = NEW_SESSION):
# Lock the related dag runs to prevent from p
uranusjr opened a new pull request, #32802:
URL: https://github.com/apache/airflow/pull/32802
This applies MappedTaskIsExpanded to BaseOperator (as well as
MappedOperator), so it is checked to be expanded if it's in a mapped task group.
Fix #30333
Fix #30334
Close #32701
VladaZakharova commented on PR #32487:
URL: https://github.com/apache/airflow/pull/32487#issuecomment-1647701412
Hi!
This system test is in our priority list now, so it is important to prepare
this test in he nearest future. What do you think about my team taking this
ticket?
--
This
antonio-antuan commented on PR #32802:
URL: https://github.com/apache/airflow/pull/32802#issuecomment-1647705874
awesome! I'll check it within a couple of days
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
uranusjr merged PR #32801:
URL: https://github.com/apache/airflow/pull/32801
--
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
This is an automated email from the ASF dual-hosted git repository.
uranusjr 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 0339f94a50 Fix failing dagrun query due to sqlalc
uranusjr commented on code in PR #32692:
URL: https://github.com/apache/airflow/pull/32692#discussion_r1272122138
##
airflow/plugins_manager.py:
##
@@ -267,6 +274,27 @@ def load_plugins_from_plugin_directory():
import_errors[file_path] = str(e)
+def load_provide
raycarter commented on PR #26766:
URL: https://github.com/apache/airflow/pull/26766#issuecomment-1647718951
Hello, is this PR in any version released? I can't find the changes in the
current version 2.6.3 or in the main-branch.
--
This is an automated message from the Apache Git Service.
moiseenkov commented on PR #32798:
URL: https://github.com/apache/airflow/pull/32798#issuecomment-1647720094
> Can you amend and force-push to fix the typoe in the commit message?
Hi @uranusjr , thanks for noticing. Fixed.
--
This is an automated message from the Apache Git Service.
uranusjr commented on PR #32000:
URL: https://github.com/apache/airflow/pull/32000#issuecomment-1647722231
I think building a DAG with `dag_maker` and then call `test` would work. The
test should be annotated with `@pytest.mark.execution_timeout` since we also
want to test for the infinite
phanikumv merged PR #32689:
URL: https://github.com/apache/airflow/pull/32689
--
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
amoghrajesh commented on PR #32487:
URL: https://github.com/apache/airflow/pull/32487#issuecomment-1647723772
Sure. If it's a priority, go ahead and take it over.
Thanks @VladaZakharova
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
This is an automated email from the ASF dual-hosted git repository.
phanikumv pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 0339f94a50 Fix failing dagrun query due to sqlalchemy 2.0 refactor
(#32801)
add 6313e52932 Add missing execute
VladaZakharova commented on PR #32487:
URL: https://github.com/apache/airflow/pull/32487#issuecomment-1647737634
> Sure. If it's a priority, go ahead and take it over.
>
> Thanks @VladaZakharova
:)
To be able to create a service account, you should have project in gcp. If
yo
NilsJPWerner commented on PR #32792:
URL: https://github.com/apache/airflow/pull/32792#issuecomment-1647767495
This looks awesome!
--
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 co
boring-cyborg[bot] commented on PR #32803:
URL: https://github.com/apache/airflow/pull/32803#issuecomment-1647774681
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
mayanktri opened a new pull request, #32803:
URL: https://github.com/apache/airflow/pull/32803
xcom push argument is incorrect in version 2.6.3. xcom_push should be
replaced with do_xcom_push in BashOperator.
--
This is an automated message from the Apache Git Service.
To respond to t
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 476db0a013 Updating con
dzhigimont commented on PR #32802:
URL: https://github.com/apache/airflow/pull/32802#issuecomment-1647809044
@uranusjr Hmm, it doesn't work in my env, you can use the test from my PR
https://github.com/apache/airflow/pull/32701
`test_upstream_in_mapped_group_with_one_failed_rule_task` to ch
Owen-CH-Leung commented on code in PR #32781:
URL: https://github.com/apache/airflow/pull/32781#discussion_r1272198290
##
tests/utils/test_serve_logs.py:
##
@@ -22,7 +22,9 @@
import jwt
import pytest
import time_machine
+from py import path
Review Comment:
Thanks. I've us
gecko655 opened a new issue, #32804:
URL: https://github.com/apache/airflow/issues/32804
### Apache Airflow version
Other Airflow 2 version (please specify below)
### What happened
### Airflow version
2.5.3+composer (The latest available airflow version in Cloud Compos
raycarter opened a new issue, #32805:
URL: https://github.com/apache/airflow/issues/32805
### Description
The iamge of xcom_sidecar is not cunfigurable (code:
[xcom_sidecar.py#36](https://github.com/apache/airflow/blob/main/airflow/providers/cncf/kubernetes/utils/xcom_sidecar.py#L36))
This is an automated email from the ASF dual-hosted git repository.
mobuchowski 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 6f75a8a917 improve performance of pr script in
mobuchowski merged PR #32735:
URL: https://github.com/apache/airflow/pull/32735
--
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
vincbeck commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272269208
##
airflow/providers/amazon/aws/hooks/redshift_data.py:
##
@@ -95,6 +100,12 @@ def execute_query(
statement_id = resp["Id"]
+if kwargs["ClusterI
mobuchowski commented on code in PR #32716:
URL: https://github.com/apache/airflow/pull/32716#discussion_r1272290431
##
airflow/models/taskinstance.py:
##
@@ -1651,16 +1646,23 @@ def signal_handler(signum, frame):
)
# Run pre_execute callback
-
mobuchowski commented on code in PR #32716:
URL: https://github.com/apache/airflow/pull/32716#discussion_r1272290431
##
airflow/models/taskinstance.py:
##
@@ -1651,16 +1646,23 @@ def signal_handler(signum, frame):
)
# Run pre_execute callback
-
Lee-W opened a new pull request, #32806:
URL: https://github.com/apache/airflow/pull/32806
As mentioned in #27837, we should do something similar to
DatabricksRunOperator instead of running the original executing logic in
DatabricksRunNowDeferrableOperator This is due to a bug that causes i
RNHTTR commented on code in PR #32709:
URL: https://github.com/apache/airflow/pull/32709#discussion_r1272305349
##
docs/apache-airflow/authoring-and-scheduling/deferring.rst:
##
@@ -20,7 +20,7 @@ Deferrable Operators & Triggers
Standard :doc:`Operators ` and :doc:`Sensors
<.
Lee-W commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272312032
##
airflow/providers/amazon/aws/hooks/redshift_data.py:
##
@@ -95,6 +100,12 @@ def execute_query(
statement_id = resp["Id"]
+if kwargs["ClusterIden
Lee-W commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272312032
##
airflow/providers/amazon/aws/hooks/redshift_data.py:
##
@@ -95,6 +100,12 @@ def execute_query(
statement_id = resp["Id"]
+if kwargs["ClusterIden
Lee-W commented on code in PR #32779:
URL: https://github.com/apache/airflow/pull/32779#discussion_r1272312846
##
airflow/providers/microsoft/azure/log/wasb_task_handler.py:
##
@@ -148,7 +146,7 @@ def _read_remote_logs(self, ti, try_number, metadata=None)
-> tuple[list[str], l
vincbeck commented on code in PR #28900:
URL: https://github.com/apache/airflow/pull/28900#discussion_r1272322945
##
airflow/models/dag.py:
##
@@ -1465,11 +1510,22 @@ def get_dagrun(
raise TypeError("You must provide either the execution_date or the
run_id")
vincbeck merged PR #32787:
URL: https://github.com/apache/airflow/pull/32787
--
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
This is an automated email from the ASF dual-hosted git repository.
vincbeck pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 6f75a8a917 improve performance of pr script in dev/stats (#32735)
add d05e42e5d2 Add `ExternalBranchPythonOperat
karakanb commented on PR #32705:
URL: https://github.com/apache/airflow/pull/32705#issuecomment-1648008286
@uranusjr done, assumed it'd go in 2.6.4, please take a look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
moiseenkov opened a new pull request, #32807:
URL: https://github.com/apache/airflow/pull/32807
1. Fixed Dataproc system tests - made sure that each test creates objects
with unique names, so they could run in parallel with no conflicts.
3. Removed unused variables.
4. Refactored sligh
amoghrajesh opened a new pull request, #32808:
URL: https://github.com/apache/airflow/pull/32808
To control mounting of the serviceAccount's API credentials onto pods,
automountServiceAccountToken property can be used. The changes can either be in
serviceAccount definitions
This is an automated email from the ASF dual-hosted git repository.
mobuchowski pushed a commit to branch load-plugins-from-providers
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit ef4ece9f9e2c038200f77d5dc9e10709ca42efd5
Author: Maciej Obuchowski
AuthorDate: Tue Jun 27 14:
This is an automated email from the ASF dual-hosted git repository.
mobuchowski pushed a change to branch load-plugins-from-providers
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit e6bd5213ec plugins: load plugins from providers
new ef4ece9f9e plugins: load plugins f
mobuchowski commented on code in PR #32692:
URL: https://github.com/apache/airflow/pull/32692#discussion_r1272367426
##
airflow/providers_manager.py:
##
@@ -1024,6 +1039,20 @@ def _discover_config(self) -> None:
if provider.data.get("config"):
self.
ivica-k commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272370482
##
airflow/providers/amazon/aws/hooks/redshift_data.py:
##
@@ -53,6 +53,7 @@ def execute_query(
database: str,
sql: str | list[str],
cluste
ivica-k commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272371045
##
airflow/providers/amazon/aws/hooks/redshift_data.py:
##
@@ -95,6 +100,12 @@ def execute_query(
statement_id = resp["Id"]
+if kwargs["ClusterId
ivica-k commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272371737
##
tests/providers/amazon/aws/hooks/test_redshift_data.py:
##
@@ -39,22 +41,53 @@ def test_conn_attribute(self):
@mock.patch("airflow.providers.amazon.aws.hooks
Lee-W commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272382745
##
airflow/providers/amazon/aws/hooks/redshift_data.py:
##
@@ -60,13 +60,17 @@ def execute_query(
with_event: bool = False,
wait_for_completion: bool
mikaeld commented on code in PR #32724:
URL: https://github.com/apache/airflow/pull/32724#discussion_r1272393274
##
chart/templates/secrets/pgbouncer-stats-secret.yaml:
##
Review Comment:
IMO there is no point in having a custom key with the included chart secret.
I believ
mikaeld commented on code in PR #32724:
URL: https://github.com/apache/airflow/pull/32724#discussion_r1272402622
##
chart/values.schema.json:
##
@@ -5341,6 +5341,22 @@
],
"$ref":
"#/definitions/io.k8s.api.core.v1.Resourc
vincbeck commented on PR #32785:
URL: https://github.com/apache/airflow/pull/32785#issuecomment-1648116560
Besides the nits mentioned by @Lee-W , it looks good to me :) Good job!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
mikaeld commented on code in PR #32724:
URL: https://github.com/apache/airflow/pull/32724#discussion_r1272402622
##
chart/values.schema.json:
##
@@ -5341,6 +5341,22 @@
],
"$ref":
"#/definitions/io.k8s.api.core.v1.Resourc
ivica-k commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272412389
##
airflow/providers/amazon/aws/operators/redshift_data.py:
##
@@ -55,6 +58,7 @@ class RedshiftDataOperator(BaseOperator):
template_fields = (
"cluste
ivica-k commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272412389
##
airflow/providers/amazon/aws/operators/redshift_data.py:
##
@@ -55,6 +58,7 @@ class RedshiftDataOperator(BaseOperator):
template_fields = (
"cluste
ivica-k commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272416092
##
airflow/providers/amazon/aws/hooks/redshift_data.py:
##
@@ -60,13 +60,17 @@ def execute_query(
with_event: bool = False,
wait_for_completion: boo
ivica-k commented on code in PR #32785:
URL: https://github.com/apache/airflow/pull/32785#discussion_r1272416728
##
airflow/providers/amazon/aws/operators/redshift_data.py:
##
@@ -55,6 +58,7 @@ class RedshiftDataOperator(BaseOperator):
template_fields = (
"cluste
vincbeck commented on PR #32756:
URL: https://github.com/apache/airflow/pull/32756#issuecomment-1648147600
It looks good! Nice! Some unit tests are failing but besides that I like it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
eladkal commented on PR #31843:
URL: https://github.com/apache/airflow/pull/31843#issuecomment-1648162930
Resolved in https://github.com/apache/airflow/pull/32787
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
eladkal closed pull request #31843: Add ExternalBranchPythonOperator
URL: https://github.com/apache/airflow/pull/31843
--
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 unsubs
bhagany commented on code in PR #30053:
URL: https://github.com/apache/airflow/pull/30053#discussion_r1272466593
##
airflow/providers/google/cloud/transfers/bigquery_to_gcs.py:
##
@@ -193,7 +193,7 @@ def _submit_job(
return hook.insert_job(
configuration=
Sighery commented on issue #32657:
URL: https://github.com/apache/airflow/issues/32657#issuecomment-1648206389
@jens-scheffler-bosch @potiuk So, tried it today [in my
fork](https://github.com/Sighery/airflow/pull/1). I think I managed to set up
the required CI checks correctly. I couldn't g
sunank200 commented on code in PR #31350:
URL: https://github.com/apache/airflow/pull/31350#discussion_r1272477650
##
airflow/providers/google/cloud/transfers/gcs_to_gcs.py:
##
@@ -464,7 +466,37 @@ def _copy_single_object(self, hook, source_object,
destination_object):
ferruzzi commented on issue #32271:
URL: https://github.com/apache/airflow/issues/32271#issuecomment-1648233538
Interesting, yeah, I see where you are coming from but I think I agree with
hussain's comment. If you are using the default trigger rules and the upstream
task failed, then this
syedahsn opened a new pull request, #32809:
URL: https://github.com/apache/airflow/pull/32809
This PR adds the deferrable option to the SQS sensor.
I refactored the existing sensor to pull out some of the code that processes
the boto API response so that it could be used by the Trigger,
jedcunningham commented on code in PR #32775:
URL: https://github.com/apache/airflow/pull/32775#discussion_r1272529966
##
airflow/configuration.py:
##
@@ -1929,6 +1942,18 @@ def
create_default_config_parser(configuration_description: dict[str, dict[str,
return parser
+
vincbeck merged PR #32785:
URL: https://github.com/apache/airflow/pull/32785
--
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
This is an automated email from the ASF dual-hosted git repository.
vincbeck 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 8012c9fce6 Add support for querying Redshift Serv
vincbeck merged PR #32664:
URL: https://github.com/apache/airflow/pull/32664
--
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
This is an automated email from the ASF dual-hosted git repository.
vincbeck 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 282854b55f Add endpoint_url in test_connection (#
vincbeck closed issue #32280: RedshiftDataOperator: Add support for Redshift
serverless clusters
URL: https://github.com/apache/airflow/issues/32280
--
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 t
yquaziii commented on issue #32793:
URL: https://github.com/apache/airflow/issues/32793#issuecomment-1648305491
Are you using depends_on_past=True in sub_dag.? if that's not the case then
the next task group should have executed.
--
This is an automated message from the Apache Git Servic
1 - 100 of 213 matches
Mail list logo