farhan0syakir opened a new pull request, #28799:
URL: https://github.com/apache/airflow/pull/28799
---
**^ Add meaningful description above**
Read the **[Pull Request
Guidelines](https://github.com/apache/airflow/blob/main/CONTRIBUTING.rst#pull-request-guidelines)**
for
uranusjr commented on code in PR #28764:
URL: https://github.com/apache/airflow/pull/28764#discussion_r1064353800
##
airflow/providers/apache/beam/operators/beam.py:
##
@@ -563,8 +582,13 @@ def __init__(
)
self.dataflow_support_impersonation = False
+
uranusjr commented on code in PR #28764:
URL: https://github.com/apache/airflow/pull/28764#discussion_r1064352909
##
airflow/providers/apache/beam/operators/beam.py:
##
@@ -563,8 +582,13 @@ def __init__(
)
self.dataflow_support_impersonation = False
+
uranusjr commented on issue #28798:
URL: https://github.com/apache/airflow/issues/28798#issuecomment-1375214889
This looks like a database configuration issue. Did you configure the
database’s character set and collation correctly?
uranusjr commented on issue #26933:
URL: https://github.com/apache/airflow/issues/26933#issuecomment-1375212752
I think this is intended, at least from my reading of the implementation.
Currently the scheduler checks how many free slots in the pool, and schedule at
most that number of task
Avphy opened a new issue, #28798:
URL: https://github.com/apache/airflow/issues/28798
### Apache Airflow version
Other Airflow 2 version (please specify below)
### What happened
Airflow version: 2.3.2
OS: Linux
When processor tries to load DAG files with non
VladaZakharova commented on issue #28343:
URL: https://github.com/apache/airflow/issues/28343#issuecomment-1375208220
@vchiapaikeo Thank you for the quick PR for this fix!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
uranusjr commented on code in PR #27428:
URL: https://github.com/apache/airflow/pull/27428#discussion_r1064342332
##
airflow/api_connexion/schemas/task_instance_schema.py:
##
@@ -33,6 +33,14 @@
from airflow.utils.state import State
+class
rajaths010494 commented on code in PR #28763:
URL: https://github.com/apache/airflow/pull/28763#discussion_r1064341941
##
airflow/providers/google/cloud/hooks/gcs.py:
##
@@ -32,18 +32,21 @@
from typing import IO, Callable, Generator, Sequence, TypeVar, cast, overload
from
uranusjr commented on code in PR #28763:
URL: https://github.com/apache/airflow/pull/28763#discussion_r1064334417
##
airflow/providers/google/cloud/hooks/gcs.py:
##
@@ -32,18 +32,21 @@
from typing import IO, Callable, Generator, Sequence, TypeVar, cast, overload
from
This is an automated email from the ASF dual-hosted git repository.
uranusjr pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from ce677862be Fix Incorrect `await_container_completion` (#28771)
add 6ca67ba98e Update dynamic-task-mapping.rst
boring-cyborg[bot] commented on PR #28797:
URL: https://github.com/apache/airflow/pull/28797#issuecomment-1375195803
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
uranusjr merged PR #28797:
URL: https://github.com/apache/airflow/pull/28797
--
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:
Avphy commented on issue #10954:
URL: https://github.com/apache/airflow/issues/10954#issuecomment-1375193978
We are also facing similar error with Arabic text in DAG file, did anybody
find solution to this issue?
`2023-01-09_05:55:04.23124 Process DagFileProcessor9-Process:
boring-cyborg[bot] commented on PR #28797:
URL: https://github.com/apache/airflow/pull/28797#issuecomment-1375169822
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
sadler-elena opened a new pull request, #28797:
URL: https://github.com/apache/airflow/pull/28797
Added missing word from sentence, using context from previous section.
**^ Add meaningful description above**
Read the **[Pull Request
mlnsharma commented on PR #27802:
URL: https://github.com/apache/airflow/pull/27802#issuecomment-1375096177
Hi @potiuk @jedcunningham @XD-DENG @bdsoha
Can you please review my code changes?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
amoghrajesh commented on issue #28737:
URL: https://github.com/apache/airflow/issues/28737#issuecomment-1375095038
Hi, @bbovenzi I am new to Airflow and would likewith to get a few things
clarified before starting.
- Do we have some kind of legends in the airflow codebase that i can
uranusjr commented on issue #24547:
URL: https://github.com/apache/airflow/issues/24547#issuecomment-1375044561
Fixed in #28313
--
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
uranusjr closed issue #24547: DAGs with Dynamic Task Mapping are not rendered
when cluster policies overwrite a parameter
URL: https://github.com/apache/airflow/issues/24547
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
uranusjr commented on code in PR #28781:
URL: https://github.com/apache/airflow/pull/28781#discussion_r1064255602
##
airflow/www/utils.py:
##
@@ -820,10 +822,24 @@ def __init__(
self.html = html
self.message = Markup(message) if html else message
-def
uranusjr commented on code in PR #28781:
URL: https://github.com/apache/airflow/pull/28781#discussion_r1064255376
##
airflow/www/utils.py:
##
@@ -820,10 +822,26 @@ def __init__(
self.html = html
self.message = Markup(message) if html else message
-def
uranusjr commented on code in PR #28781:
URL: https://github.com/apache/airflow/pull/28781#discussion_r1064255188
##
airflow/www/utils.py:
##
@@ -820,10 +822,25 @@ def __init__(
self.html = html
self.message = Markup(message) if html else message
-def
uranusjr commented on code in PR #28781:
URL: https://github.com/apache/airflow/pull/28781#discussion_r1064255188
##
airflow/www/utils.py:
##
@@ -820,10 +822,25 @@ def __init__(
self.html = html
self.message = Markup(message) if html else message
-def
uranusjr commented on code in PR #28777:
URL: https://github.com/apache/airflow/pull/28777#discussion_r1064248601
##
airflow/www/utils.py:
##
@@ -133,13 +133,25 @@ def get_mapped_summary(parent_instance, task_instances):
def get_dag_run_conf(dag_run_conf: Any) -> tuple[str
uranusjr commented on code in PR #28777:
URL: https://github.com/apache/airflow/pull/28777#discussion_r1064247537
##
airflow/www/utils.py:
##
@@ -133,13 +133,25 @@ def get_mapped_summary(parent_instance, task_instances):
def get_dag_run_conf(dag_run_conf: Any) -> tuple[str
vchiapaikeo commented on issue #28343:
URL: https://github.com/apache/airflow/issues/28343#issuecomment-1375006740
Created this PR to fix the runtime / type error:
https://github.com/apache/airflow/pull/28796
--
This is an automated message from the Apache Git Service.
To respond to the
vchiapaikeo opened a new pull request, #28796:
URL: https://github.com/apache/airflow/pull/28796
A TypeError which causes tasks to fail at runtime exists in the
BigQueryColumnCheckOperator. This was initially uncovered while looking at
another issue for this operator here:
bbovenzi commented on issue #28737:
URL: https://github.com/apache/airflow/issues/28737#issuecomment-1375004932
> @bbovenzi is this issue taken? I would like to try my hands here given
some more reference material here.
Nope! It's all yours. Feel free to ask any questions here.
bugraoz93 opened a new pull request, #28795:
URL: https://github.com/apache/airflow/pull/28795
related: #28271
Migration of `Models.Variable` to Internal API.
- set
- update
- delete
--
This is an automated message from the Apache Git Service.
To respond to the message,
Taragolis commented on code in PR #28777:
URL: https://github.com/apache/airflow/pull/28777#discussion_r1064227851
##
airflow/www/utils.py:
##
@@ -133,13 +133,25 @@ def get_mapped_summary(parent_instance, task_instances):
def get_dag_run_conf(dag_run_conf: Any) ->
github-actions[bot] commented on PR #22976:
URL: https://github.com/apache/airflow/pull/22976#issuecomment-1374969395
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
github-actions[bot] commented on PR #23079:
URL: https://github.com/apache/airflow/pull/23079#issuecomment-1374969374
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
github-actions[bot] commented on issue #27589:
URL: https://github.com/apache/airflow/issues/27589#issuecomment-1374969321
This issue has been closed because it has not received response from the
issue author.
--
This is an automated message from the Apache Git Service.
To respond to the
github-actions[bot] closed issue #27589: Scheduler pods memory leak on airflow
2.3.2
URL: https://github.com/apache/airflow/issues/27589
--
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
github-actions[bot] commented on issue #27078:
URL: https://github.com/apache/airflow/issues/27078#issuecomment-1374969340
This issue has been automatically marked as stale because it has been open
for 30 days with no response from the author. It will be closed in next 7 days
if no further
github-actions[bot] closed issue #27883: Getting 404 when clicking on download
logs button
URL: https://github.com/apache/airflow/issues/27883
--
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
github-actions[bot] commented on issue #27883:
URL: https://github.com/apache/airflow/issues/27883#issuecomment-1374969290
This issue has been closed because it has not received response from the
issue author.
--
This is an automated message from the Apache Git Service.
To respond to the
hussein-awala commented on code in PR #28777:
URL: https://github.com/apache/airflow/pull/28777#discussion_r1064216151
##
airflow/www/utils.py:
##
@@ -133,13 +133,25 @@ def get_mapped_summary(parent_instance, task_instances):
def get_dag_run_conf(dag_run_conf: Any) ->
potiuk closed issue #28793: Airflow 2.3.3 doesn't retry a task if it externally
killed
URL: https://github.com/apache/airflow/issues/28793
--
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
o-nikolas commented on code in PR #28161:
URL: https://github.com/apache/airflow/pull/28161#discussion_r1064208434
##
airflow/executors/kubernetes_executor.py:
##
@@ -749,6 +751,57 @@ def _change_state(self, key: TaskInstanceKey, state: str |
None, pod_id: str, na
potiuk commented on issue #28793:
URL: https://github.com/apache/airflow/issues/28793#issuecomment-1374937415
Any logs showing this situation ? Can you please be more specific what
happens and when ?
--
This is an automated message from the Apache Git Service.
To respond to the message,
jens-scheffler-bosch commented on PR #27063:
URL: https://github.com/apache/airflow/pull/27063#issuecomment-1374909603
> > Now time for a final review, then (in my view) ready to be merged.
>
> I don't see vote thread on the mailing list
@eladkal thanks for helping out in
yxiao1996 commented on issue #17487:
URL: https://github.com/apache/airflow/issues/17487#issuecomment-1374909408
Reproduce the scenario described in this issue with a python operator which
causes failed task at 50% chance
```
@task(task_id=f"sleep_and_randomly_fail", retries=1)
Taragolis commented on code in PR #28777:
URL: https://github.com/apache/airflow/pull/28777#discussion_r1064190069
##
airflow/www/utils.py:
##
@@ -133,13 +133,25 @@ def get_mapped_summary(parent_instance, task_instances):
def get_dag_run_conf(dag_run_conf: Any) ->
VladaZakharova commented on PR #28564:
URL: https://github.com/apache/airflow/pull/28564#issuecomment-1374904744
Hi Team :)
As for the changes in [#28284](https://github.com/apache/airflow/pull/28284)
- all the changes for autodetect=True field were also tested for the JSON
format
pierrejeambrun commented on issue #28556:
URL: https://github.com/apache/airflow/issues/28556#issuecomment-1374903312
Hello @alejandrofm,
Just assigned you :)
You can start looking at the file `airflow/www/views.py`, the class
`DagRunModelView`.
Duration is not a db
boring-cyborg[bot] commented on issue #28793:
URL: https://github.com/apache/airflow/issues/28793#issuecomment-1374902248
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
nofarm3 opened a new issue, #28793:
URL: https://github.com/apache/airflow/issues/28793
### Apache Airflow version
Other Airflow 2 version (please specify below)
### What happened
When a task get externally killed, it is marked as Failed even though it can
be retried.
potiuk commented on issue #28789:
URL: https://github.com/apache/airflow/issues/28789#issuecomment-1374901005
Sure. But I guess it will be "all-or-nothing"
--
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
VladaZakharova commented on issue #28343:
URL: https://github.com/apache/airflow/issues/28343#issuecomment-1374900424
Hi Team :)
Sorry for late answer
I was trying to reproduce the error from the bug using fields with DATETIME
datatypes, but it seems that i have faced the same problem
hussein-awala commented on code in PR #28777:
URL: https://github.com/apache/airflow/pull/28777#discussion_r1064173784
##
airflow/www/utils.py:
##
@@ -133,13 +133,25 @@ def get_mapped_summary(parent_instance, task_instances):
def get_dag_run_conf(dag_run_conf: Any) ->
eladkal closed issue #20829: Update google-cloud-container package to v2.10.1
URL: https://github.com/apache/airflow/issues/20829
--
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
eladkal commented on issue #20829:
URL: https://github.com/apache/airflow/issues/20829#issuecomment-1374848627
Closing as completed
https://github.com/apache/airflow/blob/5246c009c557b4f6bdf1cd62bf9b89a2da63f630/airflow/providers/google/provider.yaml#L86
--
This is an automated
Taragolis commented on PR #28767:
URL: https://github.com/apache/airflow/pull/28767#issuecomment-1374830419
I can't reproduce this error locally but I have an idea what could possible
wrong
Potentially callback might acquire lock
potiuk commented on issue #28740:
URL: https://github.com/apache/airflow/issues/28740#issuecomment-1374795388
> @potiuk , We upgraded to EKS cluster 1.23 but still issue persist memory
leak with respect to Workers liveness probe and scheduler pods as well.
Which memory is it ? Did
Taragolis opened a new issue, #28790:
URL: https://github.com/apache/airflow/issues/28790
### Body
Some of Hooks provide connection ability, however quite a few of them do not
provide any documentation and/or connection type (missing in the UI). It would
be nice if we add missing
Taragolis commented on PR #28767:
URL: https://github.com/apache/airflow/pull/28767#issuecomment-1374756956
@potiuk I hope it just flaky test and not something wrong with callback
mechanism.
Let keep it for a while and have a look how often it failed - just for some
statistic, I will
58 matches
Mail list logo