eladkal commented on code in PR #28538:
URL: https://github.com/apache/airflow/pull/28538#discussion_r1056114079
##
airflow/providers/apache/hive/plugins/hive_plugin.py:
##
@@ -0,0 +1,42 @@
+# Licensed to the Apache Software Foundation (ASF) under one
Review Comment:
You are
potiuk closed issue #28550: strange order of db migration job launch
URL: https://github.com/apache/airflow/issues/28550
--
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 unsu
potiuk commented on issue #25032:
URL: https://github.com/apache/airflow/issues/25032#issuecomment-1363694326
> Is it possible to expand a taskgroup from task result in release 2.5?
I believe it is @uranusjr - or I misunderstood it ?
--
This is an automated message from the Apache G
jaegwonseo opened a new issue, #28550:
URL: https://github.com/apache/airflow/issues/28550
### Official Helm Chart version
1.7.0 (latest released)
### Apache Airflow version
2.4
### Kubernetes Version
1.2.3
### Helm Chart configuration
migrateD
VladaZakharova commented on PR #28284:
URL: https://github.com/apache/airflow/pull/28284#issuecomment-1363692360
Thank you for helping me to improve my code :)
--
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
potiuk commented on code in PR #28541:
URL: https://github.com/apache/airflow/pull/28541#discussion_r1056101696
##
scripts/ci/pre_commit/pre_commit_check_provider_yaml_files.py:
##
@@ -38,6 +39,9 @@
from airflow_breeze.utils.docker_command_utils import
get_extra_docker_fla
jens-scheffler-bosch commented on PR #27063:
URL: https://github.com/apache/airflow/pull/27063#issuecomment-1363689224
Hi @pierrejeambrun - thanks again for the review! I now closed the gaps and
made the pipeline green - functional-wise the AIP-50 implementation is
completed now. Now time f
potiuk commented on code in PR #28541:
URL: https://github.com/apache/airflow/pull/28541#discussion_r1056098444
##
scripts/ci/pre_commit/pre_commit_check_provider_yaml_files.py:
##
@@ -38,6 +39,9 @@
from airflow_breeze.utils.docker_command_utils import
get_extra_docker_fla
dstandish commented on code in PR #26639:
URL: https://github.com/apache/airflow/pull/26639#discussion_r1056086480
##
airflow/executors/kubernetes_executor.py:
##
@@ -62,6 +64,50 @@
KubernetesWatchType = Tuple[str, str, Optional[str], Dict[str, str], str]
+def multi_threads
ephraimbuddy commented on code in PR #28469:
URL: https://github.com/apache/airflow/pull/28469#discussion_r1056077448
##
airflow/dag_processing/processor.py:
##
@@ -473,13 +473,21 @@ def manage_slas(self, dag: DAG, session: Session = None)
-> None:
notification_sen
dstandish commented on code in PR #26639:
URL: https://github.com/apache/airflow/pull/26639#discussion_r1056077346
##
airflow/executors/kubernetes_executor.py:
##
@@ -62,6 +64,50 @@
KubernetesWatchType = Tuple[str, str, Optional[str], Dict[str, str], str]
+def multi_threads
dstandish commented on code in PR #26639:
URL: https://github.com/apache/airflow/pull/26639#discussion_r1056073815
##
airflow/executors/kubernetes_executor.py:
##
@@ -62,6 +64,50 @@
KubernetesWatchType = Tuple[str, str, Optional[str], Dict[str, str], str]
+def multi_threads
dstandish commented on code in PR #26639:
URL: https://github.com/apache/airflow/pull/26639#discussion_r1056073449
##
airflow/executors/kubernetes_executor.py:
##
@@ -62,6 +64,50 @@
KubernetesWatchType = Tuple[str, str, Optional[str], Dict[str, str], str]
+def multi_threads
dstandish commented on code in PR #26639:
URL: https://github.com/apache/airflow/pull/26639#discussion_r1056064275
##
airflow/executors/kubernetes_executor.py:
##
@@ -370,7 +416,17 @@ def sync(self) -> None:
"""
self.log.debug("Syncing KubernetesExecutor")
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r105590
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError from e
wangyaopw commented on issue #25032:
URL: https://github.com/apache/airflow/issues/25032#issuecomment-1363603332
Hi, @potiuk
I don't think it is possible to expand a taskgroup from the result of a task
yet in 2.5.0.
For example
```
from airflow import DAG
from air
IKholopov commented on PR #28284:
URL: https://github.com/apache/airflow/pull/28284#issuecomment-1363535466
Thanks for fixing it up, Vlada!
--
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 spe
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r105590
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError from e
pingzh commented on code in PR #28477:
URL: https://github.com/apache/airflow/pull/28477#discussion_r1055962697
##
airflow/utils/log/file_task_handler.py:
##
@@ -318,6 +319,34 @@ def read(self, task_instance, try_number=None,
metadata=None):
return logs, metadata_arr
Taragolis closed issue #28547: Snowflake Connection - Failing
URL: https://github.com/apache/airflow/issues/28547
--
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
Taragolis commented on issue #28547:
URL: https://github.com/apache/airflow/issues/28547#issuecomment-1363468965
> [2022-12-22, 22:38:41 UTC] {local_task_job.py:159} INFO - Task exited with
return code Negsignal.SIGSEGV
This could reference to known issue with fork process in MacOS, t
Taragolis commented on code in PR #28525:
URL: https://github.com/apache/airflow/pull/28525#discussion_r1055947023
##
tests/providers/google/cloud/hooks/test_cloud_run.py:
##
@@ -0,0 +1,78 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor
Taragolis closed issue #28549: ImportError: cannot import name 'Markup' from
'jinja2.utils'
URL: https://github.com/apache/airflow/issues/28549
--
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 s
Taragolis commented on issue #28549:
URL: https://github.com/apache/airflow/issues/28549#issuecomment-1363460238
The error happen in `jinjasql`, the relevant issue open in their repo:
https://github.com/sripathikrishnan/jinjasql/issues/50.
However `jinjasql` is not a part of Airflow depen
github-actions[bot] commented on PR #27481:
URL: https://github.com/apache/airflow/pull/27481#issuecomment-1363458206
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 you
Amphagory opened a new issue, #28549:
URL: https://github.com/apache/airflow/issues/28549
### Apache Airflow version
2.5.0
### What happened
I am upgrading from V2.3.2 to the latest version at this time 2.5.0.
Everything seems to have upgraded fine, until I see DAG impo
boring-cyborg[bot] commented on issue #28549:
URL: https://github.com/apache/airflow/issues/28549#issuecomment-1363453233
Thanks for opening your first issue here! Be sure to follow the issue
template!
--
This is an automated message from the Apache Git Service.
To respond to the mess
jedcunningham commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055936849
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError fro
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055927732
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError from e
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055927346
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError from e
jedcunningham commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055927271
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError fro
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055927080
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError from e
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055923312
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError from e
jedcunningham commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055926509
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError fro
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055926291
##
airflow/utils/log/file_task_handler.py:
##
@@ -191,19 +191,29 @@ def _read(self, ti: TaskInstance, try_number: int,
metadata: dict[str, Any] | No
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055926224
##
airflow/utils/log/file_task_handler.py:
##
@@ -191,19 +191,29 @@ def _read(self, ti: TaskInstance, try_number: int,
metadata: dict[str, Any] | No
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055925550
##
airflow/utils/log/file_task_handler.py:
##
@@ -191,19 +191,29 @@ def _read(self, ti: TaskInstance, try_number: int,
metadata: dict[str, Any] | No
jedcunningham commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055925414
##
airflow/utils/log/file_task_handler.py:
##
@@ -191,19 +191,29 @@ def _read(self, ti: TaskInstance, try_number: int,
metadata: dict[str, Any] | No
Taragolis commented on code in PR #28484:
URL: https://github.com/apache/airflow/pull/28484#discussion_r1055925278
##
tests/providers/amazon/aws/operators/test_emr_add_steps.py:
##
@@ -224,4 +224,5 @@ def test_wait_for_completion(self, mock_add_job_flow_steps):
job_
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055924742
##
airflow/utils/log/file_task_handler.py:
##
@@ -191,19 +191,29 @@ def _read(self, ti: TaskInstance, try_number: int,
metadata: dict[str, Any] | No
uranusjr commented on code in PR #28540:
URL: https://github.com/apache/airflow/pull/28540#discussion_r1055924147
##
docs/docker-stack/entrypoint.rst:
##
@@ -415,3 +415,16 @@ Example:
apache/airflow:2.6.0.dev0-python3.8 webserver
This method is only available starting
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055923961
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError from e
Taragolis commented on PR #28484:
URL: https://github.com/apache/airflow/pull/28484#issuecomment-1363431974
>Made a minor change with how the new parameter gets used in the hook.
Because we are using @mock_emr decorator in some of the tests, it applies boto3
validation rules on the paramete
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055923312
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError from e
uranusjr commented on code in PR #28541:
URL: https://github.com/apache/airflow/pull/28541#discussion_r1055922836
##
scripts/ci/pre_commit/pre_commit_check_provider_yaml_files.py:
##
@@ -38,6 +39,9 @@
from airflow_breeze.utils.docker_command_utils import
get_extra_docker_f
jedcunningham commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055921589
##
airflow/kubernetes/pod_generator.py:
##
@@ -430,6 +419,70 @@ def construct_pod(
except Exception as e:
raise PodReconciliationError fro
boring-cyborg[bot] commented on PR #28548:
URL: https://github.com/apache/airflow/pull/28548#issuecomment-1363430028
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
federicsp opened a new pull request, #28548:
URL: https://github.com/apache/airflow/pull/28548
---
**^ Add meaningful description above**
Read the **[Pull Request
Guidelines](https://github.com/apache/airflow/blob/main/CONTRIBUTING.rst#pull-request-guidelines)**
for more i
dstandish commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055921963
##
airflow/utils/log/file_task_handler.py:
##
@@ -191,19 +191,29 @@ def _read(self, ti: TaskInstance, try_number: int,
metadata: dict[str, Any] | No
ashb commented on code in PR #28546:
URL: https://github.com/apache/airflow/pull/28546#discussion_r1055920303
##
airflow/utils/log/file_task_handler.py:
##
@@ -191,19 +191,29 @@ def _read(self, ti: TaskInstance, try_number: int,
metadata: dict[str, Any] | No
lo
Taragolis commented on code in PR #28545:
URL: https://github.com/apache/airflow/pull/28545#discussion_r1055917750
##
airflow/providers/amazon/aws/hooks/base_aws.py:
##
@@ -754,7 +754,9 @@ def test_connection(self):
"""
try:
session = self.get_sess
boring-cyborg[bot] commented on issue #28547:
URL: https://github.com/apache/airflow/issues/28547#issuecomment-1363423525
Thanks for opening your first issue here! Be sure to follow the issue
template!
--
This is an automated message from the Apache Git Service.
To respond to the mess
mgovindasamy opened a new issue, #28547:
URL: https://github.com/apache/airflow/issues/28547
### Apache Airflow version
2.5.0
### What happened
Snowflake Connection Cursor is failing all the time with SIGSEGV, the same
code just calling as pyscript is working fine
dstandish opened a new pull request, #28546:
URL: https://github.com/apache/airflow/pull/28546
This means we don't have to use ti.hostname as a proxy for pod name, and
allows us to lift the 63 charcter limit, which was a consequence of getting pod
name through hostname.
--
This is an
potiuk commented on PR #28538:
URL: https://github.com/apache/airflow/pull/28538#issuecomment-1363414047
Still need to sort out versioning, and test it, but it's close to be ready
IMHO
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
potiuk commented on code in PR #28538:
URL: https://github.com/apache/airflow/pull/28538#discussion_r1055911192
##
airflow/providers/apache/hive/plugins/hive.py:
##
@@ -0,0 +1,41 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agre
boring-cyborg[bot] commented on PR #28545:
URL: https://github.com/apache/airflow/pull/28545#issuecomment-1363405163
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
confusedpublic opened a new pull request, #28545:
URL: https://github.com/apache/airflow/pull/28545
Original `test_connection` behaviour did not account for the use of custom
endpoint urls.
This would lead to all attempts to test such connections to fail, as the
calls to
`sts.get_cal
ashb commented on code in PR #28534:
URL: https://github.com/apache/airflow/pull/28534#discussion_r1055897468
##
airflow/kubernetes/pod_generator.py:
##
@@ -349,6 +354,7 @@ def construct_pod(
scheduler_job_id: str,
run_id: str | None = None,
map_index:
ashb commented on code in PR #28534:
URL: https://github.com/apache/airflow/pull/28534#discussion_r1055897338
##
airflow/executors/kubernetes_executor.py:
##
@@ -346,6 +340,8 @@ def run_next(self, next_job: KubernetesJobType) -> None:
args=command,
pod_
potiuk commented on PR #28544:
URL: https://github.com/apache/airflow/pull/28544#issuecomment-1363397103
Saw it today in main .. Was about to 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 the
URL above
jedcunningham opened a new pull request, #28544:
URL: https://github.com/apache/airflow/pull/28544
#28198 accidentally dropped a join in a query, leading to this:
airflow/jobs/scheduler_job.py:1547 SAWarning: SELECT statement has a
cartesian product between FROM eleme
potiuk commented on code in PR #28538:
URL: https://github.com/apache/airflow/pull/28538#discussion_r1055895315
##
airflow/providers/apache/hive/plugins/hive.py:
##
@@ -0,0 +1,41 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agre
potiuk commented on code in PR #28538:
URL: https://github.com/apache/airflow/pull/28538#discussion_r1055894887
##
airflow/macros/__init__.py:
##
@@ -26,8 +26,6 @@
import dateutil # noqa
from pendulum import DateTime
-from airflow.macros import hive # noqa
Review Comment:
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 66eb282b7d Cleanup and do housekeeping with plugin
potiuk merged PR #28537:
URL: https://github.com/apache/airflow/pull/28537
--
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
dstandish commented on PR #28198:
URL: https://github.com/apache/airflow/pull/28198#issuecomment-1363386201
looks like this produces this error
```
/Users/dstandish/code/airflow/airflow/jobs/scheduler_job.py:1536 SAWarning:
SELECT statement has a cartesian product between FROM elem
syedahsn commented on PR #28484:
URL: https://github.com/apache/airflow/pull/28484#issuecomment-1363382860
Made a minor change with how the new parameter gets used in the hook.
Because we are using `@mock_emr` decorator in some of the tests, it applies
boto3 validation rules on the paramete
potiuk commented on PR #28541:
URL: https://github.com/apache/airflow/pull/28541#issuecomment-1363376218
All green.
--
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 unsub
dstandish commented on code in PR #28454:
URL: https://github.com/apache/airflow/pull/28454#discussion_r1055854652
##
airflow/utils/sqlalchemy.py:
##
@@ -153,6 +156,75 @@ def process_result_value(self, value, dialect):
return BaseSerialization.deserialize(value)
+de
ashb opened a new pull request, #28543:
URL: https://github.com/apache/airflow/pull/28543
`getboolean` and other typed get functions were issuing warnings from
"inside" themselves.
Before:
```
$ python ./airflow/airflow/kubernetes/kube_client.py
/home/ash/code/airflow/a
ashb opened a new pull request, #28542:
URL: https://github.com/apache/airflow/pull/28542
We don't do anything fancy in any of them that wouldn't work across multiple
processes.
By default/as invoked right now this makes no difference to performance, but
if we add `-j auto` it shaves
michaelmicheal commented on code in PR #28481:
URL: https://github.com/apache/airflow/pull/28481#discussion_r1055846581
##
airflow/models/dagwarning.py:
##
@@ -79,7 +83,12 @@ def purge_inactive_dag_warnings(cls, session: Session =
NEW_SESSION) -> None:
query = sess
potiuk commented on code in PR #28537:
URL: https://github.com/apache/airflow/pull/28537#discussion_r1055846277
##
docs/apache-airflow/howto/custom-view-plugin.rst:
##
@@ -48,73 +43,32 @@ Custom view Registration
A custom view with object reference t
dstandish commented on code in PR #28454:
URL: https://github.com/apache/airflow/pull/28454#discussion_r1055844290
##
airflow/utils/sqlalchemy.py:
##
@@ -153,6 +156,75 @@ def process_result_value(self, value, dialect):
return BaseSerialization.deserialize(value)
+de
potiuk commented on code in PR #28537:
URL: https://github.com/apache/airflow/pull/28537#discussion_r1055841466
##
docs/apache-airflow/howto/custom-view-plugin.rst:
##
@@ -48,73 +43,32 @@ Custom view Registration
A custom view with object reference t
potiuk closed issue #25032: Dynamic Task Mapping - Depth-first execution
URL: https://github.com/apache/airflow/issues/25032
--
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
potiuk commented on issue #25032:
URL: https://github.com/apache/airflow/issues/25032#issuecomment-1363330299
It's already implemented in 2.5.0 - via TaskGroup Mapping.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
jedcunningham commented on code in PR #28538:
URL: https://github.com/apache/airflow/pull/28538#discussion_r1055837152
##
airflow/macros/__init__.py:
##
@@ -26,8 +26,6 @@
import dateutil # noqa
from pendulum import DateTime
-from airflow.macros import hive # noqa
Review C
jedcunningham commented on code in PR #28537:
URL: https://github.com/apache/airflow/pull/28537#discussion_r1055827387
##
docs/apache-airflow/howto/custom-view-plugin.rst:
##
@@ -48,73 +43,32 @@ Custom view Registration
A custom view with object refe
potiuk commented on code in PR #28538:
URL: https://github.com/apache/airflow/pull/28538#discussion_r1055825466
##
airflow/providers/apache/hive/plugins/hive_plugin.py:
##
@@ -0,0 +1,42 @@
+# Licensed to the Apache Software Foundation (ASF) under one
Review Comment:
Should w
XD-DENG commented on PR #28540:
URL: https://github.com/apache/airflow/pull/28540#issuecomment-1363302299
> I would not be as strict here - we already endorse a number of development
tools in our docs. (and this is such a tool).
But at least it should be confirmed to be well-back
potiuk commented on PR #28540:
URL: https://github.com/apache/airflow/pull/28540#issuecomment-1363300844
> > Fair enough, so your recommended change is just to note that this can be
done with pypi proxies but avoid mentioning one?
>
> Yes I believe we need to avoid mentioning one.
potiuk commented on PR #28534:
URL: https://github.com/apache/airflow/pull/28534#issuecomment-1363295309
> wow this may be record for most approved PR :)
Let me approve it again to make it closer to record.
--
This is an automated message from the Apache Git Service.
To respond to t
ashb commented on PR #28511:
URL: https://github.com/apache/airflow/pull/28511#issuecomment-1363285671
Given pod mutation hook exists this just adds config sprawl for a very
uncommon use case - I'm closing this PR
--
This is an automated message from the Apache Git Service.
To respond to
ashb closed pull request #28511: allow a configurable prefix for pod names
created by kubernetes executor
URL: https://github.com/apache/airflow/pull/28511
--
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
wangyaopw commented on issue #25032:
URL: https://github.com/apache/airflow/issues/25032#issuecomment-1363282394
+1
There is a highly desirable feature in the community. It would be awesome if
Airflow can support this in the near future.
--
This is an automated message from the Apa
vincbeck commented on code in PR #28502:
URL: https://github.com/apache/airflow/pull/28502#discussion_r1055788988
##
airflow/dag_processing/processor.py:
##
@@ -365,8 +367,10 @@ def __init__(self, dag_ids: list[str] | None,
dag_directory: str, log: logging.L
self._dag_
vincbeck commented on code in PR #28476:
URL: https://github.com/apache/airflow/pull/28476#discussion_r1055787153
##
airflow/api_internal/endpoints/rpc_api_endpoint.py:
##
@@ -68,7 +70,10 @@ def internal_airflow_api(
log.debug("Calling method %.", {method_name})
try:
dimberman commented on code in PR #28454:
URL: https://github.com/apache/airflow/pull/28454#discussion_r1055774132
##
airflow/utils/sqlalchemy.py:
##
@@ -153,6 +156,75 @@ def process_result_value(self, value, dialect):
return BaseSerialization.deserialize(value)
+de
potiuk commented on PR #28538:
URL: https://github.com/apache/airflow/pull/28538#issuecomment-1363243094
> Oh... I just more interested in a hypothetical possibility rather than
move existed one or implement new one.
>
> Anyway this approach could add ability of add provider specific
potiuk opened a new pull request, #28541:
URL: https://github.com/apache/airflow/pull/28541
The provider validation pre-commit is now a lot slower after #28516 but it
turned out that it has been also doing a little too much.
It worked in the way (against the original design) that when
Taragolis commented on PR #28538:
URL: https://github.com/apache/airflow/pull/28538#issuecomment-1363225566
Oh... I just more interested in a hypothetical possibility rather than move
existed one or implement new one.
Anyway this approach could add ability of add provider specific `fi
potiuk commented on PR #28300:
URL: https://github.com/apache/airflow/pull/28300#issuecomment-1363215643
One other point (which very much concurs with what I described in my
proposal about executor is actually something that @Taragolis noticed.
https://github.com/apache/airflow/pull
potiuk commented on PR #28538:
URL: https://github.com/apache/airflow/pull/28538#issuecomment-1363208676
> Whoa!!! I never thought from this side.
>
> That mean potentially we could have CeleryExecutor into celery package and
K8S Executors inside cncf.kubernetes package?
Execut
dstandish commented on PR #28237:
URL: https://github.com/apache/airflow/pull/28237#issuecomment-1363195912
i am not sure it does.
how does it?
FTH gets the pod name from ti.hostname. If you store IP in ti.hostname,
then now you are in even worse situation.
And note
vandonr-amz commented on code in PR #28528:
URL: https://github.com/apache/airflow/pull/28528#discussion_r1055725594
##
airflow/sensors/base.py:
##
@@ -256,14 +256,13 @@ def _get_next_poke_interval(
return new_interval
def prepare_for_execution(self) -> BaseOpera
VinceLegendre commented on code in PR #28525:
URL: https://github.com/apache/airflow/pull/28525#discussion_r1055724844
##
tests/providers/google/cloud/hooks/test_cloud_run.py:
##
@@ -0,0 +1,78 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contrib
XD-DENG commented on PR #28540:
URL: https://github.com/apache/airflow/pull/28540#issuecomment-1363191782
> Fair enough, so your recommended change is just to note that this can be
done with pypi proxies but avoid mentioning one?
Yes I believe we need to avoid mentioning one.
O
dstandish commented on code in PR #28534:
URL: https://github.com/apache/airflow/pull/28534#discussion_r1055721343
##
airflow/executors/kubernetes_executor.py:
##
@@ -346,6 +340,7 @@ def run_next(self, next_job: KubernetesJobType) -> None:
args=command,
1 - 100 of 207 matches
Mail list logo