[GitHub] [airflow] feng-tao commented on issue #4640: [RFC] [WIP] Feature/flask restful

feng-tao commented on issue #4640: [RFC] [WIP] Feature/flask restful URL: https://github.com/apache/airflow/pull/4640#issuecomment-475839577 @drewsonne @ashb I think the AIP for this change has pass, what is the next step?

[GitHub] [airflow] feng-tao commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit

feng-tao commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit URL: https://github.com/apache/airflow/pull/4949#discussion_r268382201 ## File path: airflow/jobs.py ## @@ -2300,9 +2297,35 @@ def _per_task_process(task, key, ti,

[GitHub] [airflow] milton0825 commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit

milton0825 commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit URL: https://github.com/apache/airflow/pull/4949#discussion_r268381262 ## File path: airflow/jobs.py ## @@ -2300,9 +2297,35 @@ def _per_task_process(task, key, ti,

[GitHub] [airflow] feng-tao commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit

feng-tao commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit URL: https://github.com/apache/airflow/pull/4949#discussion_r268381021 ## File path: airflow/jobs.py ## @@ -2300,9 +2297,35 @@ def _per_task_process(task, key, ti,

[GitHub] [airflow] zhongjiajie commented on a change in pull request #4887: [AIRFLOW-4055] Add AWS SQS Sensor

zhongjiajie commented on a change in pull request #4887: [AIRFLOW-4055] Add AWS SQS Sensor URL: https://github.com/apache/airflow/pull/4887#discussion_r268380566 ## File path: airflow/contrib/sensors/aws_sqs_sensor.py ## @@ -0,0 +1,88 @@ +# -*- coding: utf-8 -*- +# +#

[GitHub] [airflow] zhongjiajie commented on a change in pull request #4887: [AIRFLOW-4055] Add AWS SQS Sensor

zhongjiajie commented on a change in pull request #4887: [AIRFLOW-4055] Add AWS SQS Sensor URL: https://github.com/apache/airflow/pull/4887#discussion_r268380672 ## File path: airflow/contrib/sensors/aws_sqs_sensor.py ## @@ -0,0 +1,88 @@ +# -*- coding: utf-8 -*- +# +#

[GitHub] [airflow] feng-tao commented on issue #4829: [AIRFLOW-3993] Change SalesforceHook and add tests

feng-tao commented on issue #4829: [AIRFLOW-3993] Change SalesforceHook and add tests URL: https://github.com/apache/airflow/pull/4829#issuecomment-475835675 @feluelle , could you rebase your pr with master? This is an

[GitHub] [airflow] feng-tao commented on issue #4569: [AIRFLOW-3745] Fix viewer not able to view dag details

feng-tao commented on issue #4569: [AIRFLOW-3745] Fix viewer not able to view dag details URL: https://github.com/apache/airflow/pull/4569#issuecomment-475835209 @ashb , pr posted (https://github.com/apache/airflow/pull/4960)

[GitHub] [airflow] feng-tao commented on issue #4808: [AIRFLOW_3982] Update DagRun state based on its tasks rather than DAG's

feng-tao commented on issue #4808: [AIRFLOW_3982] Update DagRun state based on its tasks rather than DAG's URL: https://github.com/apache/airflow/pull/4808#issuecomment-475834939 one small nit, LGTM This is an automated

[GitHub] [airflow] feng-tao commented on a change in pull request #4808: [AIRFLOW_3982] Update DagRun state based on its tasks rather than DAG's

feng-tao commented on a change in pull request #4808: [AIRFLOW_3982] Update DagRun state based on its tasks rather than DAG's URL: https://github.com/apache/airflow/pull/4808#discussion_r268380301 ## File path: tests/test_jobs.py ## @@ -2428,6 +2428,24 @@ def

[GitHub] [airflow] feng-tao commented on a change in pull request #4808: [AIRFLOW_3982] Update DagRun state based on its tasks rather than DAG's

feng-tao commented on a change in pull request #4808: [AIRFLOW_3982] Update DagRun state based on its tasks rather than DAG's URL: https://github.com/apache/airflow/pull/4808#discussion_r268379986 ## File path: tests/test_jobs.py ## @@ -2428,6 +2428,24 @@ def

[GitHub] [airflow] feng-tao commented on a change in pull request #4808: [AIRFLOW_3982] Update DagRun state based on its tasks rather than DAG's

feng-tao commented on a change in pull request #4808: [AIRFLOW_3982] Update DagRun state based on its tasks rather than DAG's URL: https://github.com/apache/airflow/pull/4808#discussion_r268379986 ## File path: tests/test_jobs.py ## @@ -2428,6 +2428,24 @@ def

[GitHub] [airflow] milton0825 commented on issue #4949: [AIRFLOW-1557] Backfill should respect pool limit

milton0825 commented on issue #4949: [AIRFLOW-1557] Backfill should respect pool limit URL: https://github.com/apache/airflow/pull/4949#issuecomment-475834272 @ashb @feng-tao ready for another look This is an automated

[GitHub] [airflow] zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268379885 ## File path: airflow/contrib/hooks/dingding_webhook_hook.py ## @@ -0,0 +1,121 @@ +# -*- coding:

[GitHub] [airflow] zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268379801 ## File path: airflow/contrib/hooks/dingding_webhook_hook.py ## @@ -0,0 +1,121 @@ +# -*- coding:

[GitHub] [airflow] pgagnon commented on issue #4648: [AIRFLOW-3274] Add run_as_user and fs_group options for Kubernetes

pgagnon commented on issue #4648: [AIRFLOW-3274] Add run_as_user and fs_group options for Kubernetes URL: https://github.com/apache/airflow/pull/4648#issuecomment-475830932 @dimberman @ashb From what I understand the window for 1.10.3 is closing soon. Do you think we can get this in? I am

[GitHub] [airflow] milton0825 commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit

milton0825 commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit URL: https://github.com/apache/airflow/pull/4949#discussion_r268376225 ## File path: airflow/config_templates/default_test.cfg ## @@ -48,6 +48,7 @@ dag_concurrency =

[GitHub] [airflow] milton0825 commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit

milton0825 commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit URL: https://github.com/apache/airflow/pull/4949#discussion_r268375067 ## File path: airflow/jobs.py ## @@ -2300,8 +2301,33 @@ def _per_task_process(task, key, ti,

[GitHub] [airflow] mik-laj commented on issue #4900: [AIRFLOW-3362] [WIP]Template to support jinja2 native python types

mik-laj commented on issue #4900: [AIRFLOW-3362] [WIP]Template to support jinja2 native python types URL: https://github.com/apache/airflow/pull/4900#issuecomment-475824381 Have you analyzed the use of literal_eval? It is currently used in some operators

[GitHub] [airflow] ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268365670 ## File path: airflow/contrib/hooks/dingding_webhook_hook.py ## @@ -0,0 +1,121 @@ +# -*- coding: utf-8

[GitHub] [airflow] ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268365670 ## File path: airflow/contrib/hooks/dingding_webhook_hook.py ## @@ -0,0 +1,121 @@ +# -*- coding: utf-8

[GitHub] [airflow] ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268365342 ## File path: airflow/contrib/hooks/dingding_webhook_hook.py ## @@ -0,0 +1,121 @@ +# -*- coding: utf-8

[GitHub] [airflow] ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268364976 ## File path: airflow/contrib/hooks/dingding_webhook_hook.py ## @@ -0,0 +1,121 @@ +# -*- coding: utf-8

[GitHub] [airflow] ashb commented on issue #4705: [AIRFLOW-3743] Unify different methods of working out AIRFLOW_HOME

ashb commented on issue #4705: [AIRFLOW-3743] Unify different methods of working out AIRFLOW_HOME URL: https://github.com/apache/airflow/pull/4705#issuecomment-475809406 @XD-DENG PTAnotherL :) This is an automated message

[GitHub] [airflow] ashb commented on a change in pull request #4705: [AIRFLOW-3743] Unify different methods of working out AIRFLOW_HOME

ashb commented on a change in pull request #4705: [AIRFLOW-3743] Unify different methods of working out AIRFLOW_HOME URL: https://github.com/apache/airflow/pull/4705#discussion_r268362887 ## File path: airflow/configuration.py ## @@ -530,6 +530,24 @@ def

[jira] [Created] (AIRFLOW-4146) CgroupTaskRunner is not functioning

Junda Yang created AIRFLOW-4146: --- Summary: CgroupTaskRunner is not functioning Key: AIRFLOW-4146 URL: https://issues.apache.org/jira/browse/AIRFLOW-4146 Project: Apache Airflow Issue Type: Bug

[GitHub] [airflow] ashb merged pull request #4961: [AIRFLOW-XXX] Add Daniel to the committer list

ashb merged pull request #4961: [AIRFLOW-XXX] Add Daniel to the committer list URL: https://github.com/apache/airflow/pull/4961 This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [airflow] feng-tao commented on issue #4961: [AIRFLOW-XXX] Add Daniel to the committer list

feng-tao commented on issue #4961: [AIRFLOW-XXX] Add Daniel to the committer list URL: https://github.com/apache/airflow/pull/4961#issuecomment-475805613 cc @XD-DENG @dimberman This is an automated message from the Apache

[GitHub] [airflow] feng-tao opened a new pull request #4961: [AIRFLOW-XXX] Add Daniel to the committer list

feng-tao opened a new pull request #4961: [AIRFLOW-XXX] Add Daniel to the committer list URL: https://github.com/apache/airflow/pull/4961 Make sure you have checked _all_ steps below. ### Jira - [ ] My PR addresses the following [Airflow

[GitHub] [airflow] mans2singh commented on issue #4887: [AIRFLOW-4055] Add AWS SQS Sensor

mans2singh commented on issue #4887: [AIRFLOW-4055] Add AWS SQS Sensor URL: https://github.com/apache/airflow/pull/4887#issuecomment-475799403 @mik-laj @zhongjiajie @feng-tao team - Please let me know if you have any additional comments for me. Thanks for your advice.

[GitHub] [airflow] codecov-io edited a comment on issue #4960: [AIRFLOW-4145] Allow RBAC roles permissions , VM to be overridable

codecov-io edited a comment on issue #4960: [AIRFLOW-4145] Allow RBAC roles permissions , VM to be overridable URL: https://github.com/apache/airflow/pull/4960#issuecomment-475790381 # [Codecov](https://codecov.io/gh/apache/airflow/pull/4960?src=pr=h1) Report > Merging

[GitHub] [airflow] codecov-io commented on issue #4960: [AIRFLOW-4145] Allow RBAC roles permissions , VM to be overridable

codecov-io commented on issue #4960: [AIRFLOW-4145] Allow RBAC roles permissions , VM to be overridable URL: https://github.com/apache/airflow/pull/4960#issuecomment-475790381 # [Codecov](https://codecov.io/gh/apache/airflow/pull/4960?src=pr=h1) Report > Merging

[jira] [Comment Edited] (AIRFLOW-4139) DAG versioning

[ https://issues.apache.org/jira/browse/AIRFLOW-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799271#comment-16799271 ] Tao Feng edited comment on AIRFLOW-4139 at 3/22/19 7:07 PM: there is a long

[jira] [Updated] (AIRFLOW-4139) DAG versioning

[ https://issues.apache.org/jira/browse/AIRFLOW-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chao-Han Tsai updated AIRFLOW-4139: --- Description: Currently, running DagRun will be impacted if we change the DAG file in the

[jira] [Commented] (AIRFLOW-4139) DAG versioning

[ https://issues.apache.org/jira/browse/AIRFLOW-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799271#comment-16799271 ] Tao Feng commented on AIRFLOW-4139: --- there is a long

[jira] [Commented] (AIRFLOW-4139) DAG versioning

[ https://issues.apache.org/jira/browse/AIRFLOW-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799264#comment-16799264 ] Chao-Han Tsai commented on AIRFLOW-4139: I took a quick scan of

[jira] [Updated] (AIRFLOW-4139) DAG versioning

[ https://issues.apache.org/jira/browse/AIRFLOW-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chao-Han Tsai updated AIRFLOW-4139: --- Description: Currently, running DagRun will be impacted if we change the DAG file in the

[jira] [Updated] (AIRFLOW-4139) DAG versioning

[ https://issues.apache.org/jira/browse/AIRFLOW-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chao-Han Tsai updated AIRFLOW-4139: --- Description: Currently, running DagRun will be impacted if we change the DAG file in the

[jira] [Updated] (AIRFLOW-4139) DAG versioning

[ https://issues.apache.org/jira/browse/AIRFLOW-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chao-Han Tsai updated AIRFLOW-4139: --- Description: Currently, running DagRun will be impacted if we change the DAG file in the

[jira] [Commented] (AIRFLOW-4139) DAG versioning

[ https://issues.apache.org/jira/browse/AIRFLOW-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799265#comment-16799265 ] Chao-Han Tsai commented on AIRFLOW-4139: I think I should better add more description as it

[GitHub] [airflow] zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268292843 ## File path: airflow/contrib/hooks/dingding_webhook_hook.py ## @@ -0,0 +1,121 @@ +# -*- coding:

[GitHub] [airflow] zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268291624 ## File path: airflow/utils/db.py ## @@ -286,6 +286,13 @@ def initdb(): Connection(

[GitHub] [airflow] zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268291701 ## File path: airflow/contrib/hooks/dingding_webhook_hook.py ## @@ -0,0 +1,121 @@ +# -*- coding:

[GitHub] [airflow] zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268290966 ## File path: airflow/contrib/operators/dingding_webhook_operator.py ## @@ -0,0 +1,73 @@ +# -*-

[GitHub] [airflow] zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

zhongjiajie commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268290786 ## File path: airflow/contrib/operators/dingding_webhook_operator.py ## @@ -0,0 +1,73 @@ +# -*-

[GitHub] [airflow] feng-tao opened a new pull request #4960: [AIRFLOW-4145] Allow RBAC roles permissions , VM to be overridable

feng-tao opened a new pull request #4960: [AIRFLOW-4145] Allow RBAC roles permissions , VM to be overridable URL: https://github.com/apache/airflow/pull/4960 Make sure you have checked _all_ steps below. ### Jira - [x] My PR addresses the following [Airflow

[GitHub] [airflow] feng-tao commented on issue #4960: [AIRFLOW-4145] Allow RBAC roles permissions , VM to be overridable

feng-tao commented on issue #4960: [AIRFLOW-4145] Allow RBAC roles permissions , VM to be overridable URL: https://github.com/apache/airflow/pull/4960#issuecomment-475729174 PTAL @ashb @XD-DENG This is an automated message

[jira] [Commented] (AIRFLOW-4145) Allow RBAC roles permissions , VM to be overridable

[ https://issues.apache.org/jira/browse/AIRFLOW-4145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799236#comment-16799236 ] ASF GitHub Bot commented on AIRFLOW-4145: - feng-tao commented on pull request #4960:

[jira] [Created] (AIRFLOW-4145) Allow RBAC roles permissions , VM to be overridable

Tao Feng created AIRFLOW-4145: - Summary: Allow RBAC roles permissions , VM to be overridable Key: AIRFLOW-4145 URL: https://issues.apache.org/jira/browse/AIRFLOW-4145 Project: Apache Airflow

[GitHub] [airflow] mgaggero commented on issue #4852: [AIRFLOW-3152] Implements init-containers in Kubernetes Pod Operator

mgaggero commented on issue #4852: [AIRFLOW-3152] Implements init-containers in Kubernetes Pod Operator URL: https://github.com/apache/airflow/pull/4852#issuecomment-475726605 > @mgaggero why are you PRing this against the stable branch? Also could you please add a test? I wrote

[GitHub] [airflow] bnutt commented on issue #4627: [AIRFLOW-3258] K8S executor environment variables section.

bnutt commented on issue #4627: [AIRFLOW-3258] K8S executor environment variables section. URL: https://github.com/apache/airflow/pull/4627#issuecomment-475725141 Has anyone had an issue with using this functionality by setting environment variables for the scheduler? I am trying

[GitHub] [airflow] mgaggero commented on a change in pull request #4852: [AIRFLOW-3152] Implements init-containers in Kubernetes Pod Operator

mgaggero commented on a change in pull request #4852: [AIRFLOW-3152] Implements init-containers in Kubernetes Pod Operator URL: https://github.com/apache/airflow/pull/4852#discussion_r268282837 ## File path: airflow/contrib/kubernetes/init_container.py ## @@ -0,0 +1,51 @@

[jira] [Commented] (AIRFLOW-4139) DAG versioning

[ https://issues.apache.org/jira/browse/AIRFLOW-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799193#comment-16799193 ] Tao Feng commented on AIRFLOW-4139: --- [~milton0825], I wonder what is the difference between this vs

[jira] [Commented] (AIRFLOW-4139) DAG versioning

[ https://issues.apache.org/jira/browse/AIRFLOW-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799194#comment-16799194 ] Tao Feng commented on AIRFLOW-4139: --- For AIP12, there are couples of people that have been working on

[GitHub] [airflow] feng-tao commented on issue #4949: [AIRFLOW-1557] Backfill should respect pool limit

feng-tao commented on issue #4949: [AIRFLOW-1557] Backfill should respect pool limit URL: https://github.com/apache/airflow/pull/4949#issuecomment-475699583 @milton0825 , I kinda agree with @ashb . I think pooling is to use for limit resources for different teams which having a different

[GitHub] [airflow] milton0825 commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit

milton0825 commented on a change in pull request #4949: [AIRFLOW-1557] Backfill should respect pool limit URL: https://github.com/apache/airflow/pull/4949#discussion_r268257800 ## File path: airflow/config_templates/default_airflow.cfg ## @@ -125,6 +125,10 @@

[jira] [Resolved] (AIRFLOW-4144) add description of is_delete_operator_pod

[ https://issues.apache.org/jira/browse/AIRFLOW-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Imberman resolved AIRFLOW-4144. -- Resolution: Fixed > add description of is_delete_operator_pod >

[jira] [Commented] (AIRFLOW-4144) add description of is_delete_operator_pod

[ https://issues.apache.org/jira/browse/AIRFLOW-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799173#comment-16799173 ] ASF subversion and git services commented on AIRFLOW-4144: -- Commit

[jira] [Created] (AIRFLOW-4144) add description of is_delete_operator_pod

Daniel Imberman created AIRFLOW-4144: Summary: add description of is_delete_operator_pod Key: AIRFLOW-4144 URL: https://issues.apache.org/jira/browse/AIRFLOW-4144 Project: Apache Airflow

[jira] [Updated] (AIRFLOW-4144) add description of is_delete_operator_pod

[ https://issues.apache.org/jira/browse/AIRFLOW-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Imberman updated AIRFLOW-4144: - Fix Version/s: 1.10.3 > add description of is_delete_operator_pod >

[jira] [Commented] (AIRFLOW-4144) add description of is_delete_operator_pod

[ https://issues.apache.org/jira/browse/AIRFLOW-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799172#comment-16799172 ] ASF subversion and git services commented on AIRFLOW-4144: -- Commit

[jira] [Commented] (AIRFLOW-4144) add description of is_delete_operator_pod

[ https://issues.apache.org/jira/browse/AIRFLOW-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799171#comment-16799171 ] ASF GitHub Bot commented on AIRFLOW-4144: - dimberman commented on pull request #4943:

[GitHub] [airflow] dimberman merged pull request #4943: [AIRFLOW-4144] add description of is_delete_operator_pod

dimberman merged pull request #4943: [AIRFLOW-4144] add description of is_delete_operator_pod URL: https://github.com/apache/airflow/pull/4943 This is an automated message from the Apache Git Service. To respond to the

[jira] [Assigned] (AIRFLOW-4143) Airflow unaware of worker pods being terminated or failing without being able for Local Executor service updating the task state.

[ https://issues.apache.org/jira/browse/AIRFLOW-4143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Bramhall reassigned AIRFLOW-4143: -- Assignee: Paul Bramhall > Airflow unaware of worker pods being terminated or

[GitHub] [airflow] marengaz commented on a change in pull request #4943: [AIRFLOW-XXX] add description of is_delete_operator_pod

marengaz commented on a change in pull request #4943: [AIRFLOW-XXX] add description of is_delete_operator_pod URL: https://github.com/apache/airflow/pull/4943#discussion_r268237746 ## File path: airflow/contrib/operators/kubernetes_pod_operator.py ## @@ -80,6 +80,10 @@

[jira] [Created] (AIRFLOW-4143) Airflow unaware of worker pods being terminated or failing without being able for Local Executor service updating the task state.

Paul Bramhall created AIRFLOW-4143: -- Summary: Airflow unaware of worker pods being terminated or failing without being able for Local Executor service updating the task state. Key: AIRFLOW-4143 URL:

[jira] [Updated] (AIRFLOW-4127) Azure Container Instance Hook _get_instance_view bug

[ https://issues.apache.org/jira/browse/AIRFLOW-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaodong DENG updated AIRFLOW-4127: --- Fix Version/s: (was: 2.0.0) 1.10.3 > Azure Container Instance Hook

[jira] [Commented] (AIRFLOW-4002) Optionally start debugger on uncaught exceptions in `airflow test`

[ https://issues.apache.org/jira/browse/AIRFLOW-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799093#comment-16799093 ] ASF subversion and git services commented on AIRFLOW-4002: -- Commit

[GitHub] [airflow] dimberman commented on issue #4852: [AIRFLOW-3152] Implements init-containers in Kubernetes Pod Operator

dimberman commented on issue #4852: [AIRFLOW-3152] Implements init-containers in Kubernetes Pod Operator URL: https://github.com/apache/airflow/pull/4852#issuecomment-475674348 @mgaggero I changed the base branch to master, could you please rebase?

[GitHub] [airflow] darrenhaken commented on issue #4636: [AIRFLOW-3737] Kubernetes executor cannot handle long dag/task names

darrenhaken commented on issue #4636: [AIRFLOW-3737] Kubernetes executor cannot handle long dag/task names URL: https://github.com/apache/airflow/pull/4636#issuecomment-475666931 Thanks so much for all of this! @ashb when do you expect 1.10.3 to be released?

[GitHub] [airflow] codecov-io commented on issue #4919: [AIRFLOW-4093] Throw exception if job failed or cancelled or retry too many times

codecov-io commented on issue #4919: [AIRFLOW-4093] Throw exception if job failed or cancelled or retry too many times URL: https://github.com/apache/airflow/pull/4919#issuecomment-475666708 # [Codecov](https://codecov.io/gh/apache/airflow/pull/4919?src=pr=h1) Report > :exclamation: No

[jira] [Updated] (AIRFLOW-4140) Pause/unpause button not working

[ https://issues.apache.org/jira/browse/AIRFLOW-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ash Berlin-Taylor updated AIRFLOW-4140: --- Affects Version/s: (was: 1.10.2) > Pause/unpause button not working >

[jira] [Resolved] (AIRFLOW-4140) Pause/unpause button not working

[ https://issues.apache.org/jira/browse/AIRFLOW-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ash Berlin-Taylor resolved AIRFLOW-4140. Resolution: Fixed Fixed by re-writing the broken commit in v1-10-stable branch

[jira] [Commented] (AIRFLOW-3737) Kubernetes executor cannot handle long dag/task names

[ https://issues.apache.org/jira/browse/AIRFLOW-3737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799109#comment-16799109 ] ASF subversion and git services commented on AIRFLOW-3737: -- Commit

[jira] [Commented] (AIRFLOW-3737) Kubernetes executor cannot handle long dag/task names

[ https://issues.apache.org/jira/browse/AIRFLOW-3737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799108#comment-16799108 ] ASF subversion and git services commented on AIRFLOW-3737: -- Commit

[GitHub] [airflow] ashb commented on issue #4636: [AIRFLOW-3737] Kubernetes executor cannot handle long dag/task names

ashb commented on issue #4636: [AIRFLOW-3737] Kubernetes executor cannot handle long dag/task names URL: https://github.com/apache/airflow/pull/4636#issuecomment-475663685 Thanks @PaulW, I'll get this in 1.10.3 too! This

[jira] [Commented] (AIRFLOW-3737) Kubernetes executor cannot handle long dag/task names

[ https://issues.apache.org/jira/browse/AIRFLOW-3737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799106#comment-16799106 ] ASF GitHub Bot commented on AIRFLOW-3737: - ashb commented on pull request #4636: [AIRFLOW-3737]

[GitHub] [airflow] ashb merged pull request #4636: [AIRFLOW-3737] Kubernetes executor cannot handle long dag/task names

ashb merged pull request #4636: [AIRFLOW-3737] Kubernetes executor cannot handle long dag/task names URL: https://github.com/apache/airflow/pull/4636 This is an automated message from the Apache Git Service. To respond to

[GitHub] [airflow] ashb commented on issue #4959: [AIRFLOW-4142] 'DagRun' has no attribute 'task_id'

ashb commented on issue #4959: [AIRFLOW-4142] 'DagRun' has no attribute 'task_id' URL: https://github.com/apache/airflow/pull/4959#issuecomment-475662734 This leaves DagRun objects not being deleted - that doesn't sound like the right fix.

[jira] [Commented] (AIRFLOW-3980) Unify logger

[ https://issues.apache.org/jira/browse/AIRFLOW-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799091#comment-16799091 ] ASF subversion and git services commented on AIRFLOW-3980: -- Commit

[jira] [Commented] (AIRFLOW-4122) Remove chain function in airflow.utils

[ https://issues.apache.org/jira/browse/AIRFLOW-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799097#comment-16799097 ] ASF subversion and git services commented on AIRFLOW-4122: -- Commit

[jira] [Commented] (AIRFLOW-4122) Remove chain function in airflow.utils

[ https://issues.apache.org/jira/browse/AIRFLOW-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799096#comment-16799096 ] ASF subversion and git services commented on AIRFLOW-4122: -- Commit

[jira] [Commented] (AIRFLOW-3945) Row of NULLs inserted when not changing permission views

[ https://issues.apache.org/jira/browse/AIRFLOW-3945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799100#comment-16799100 ] ASF subversion and git services commented on AIRFLOW-3945: -- Commit

[jira] [Commented] (AIRFLOW-4106) Instrument starving tasks in pool

[ https://issues.apache.org/jira/browse/AIRFLOW-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799098#comment-16799098 ] ASF subversion and git services commented on AIRFLOW-4106: -- Commit

[jira] [Commented] (AIRFLOW-4107) Instrument executor

[ https://issues.apache.org/jira/browse/AIRFLOW-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799094#comment-16799094 ] ASF subversion and git services commented on AIRFLOW-4107: -- Commit

[jira] [Commented] (AIRFLOW-4123) Add Exception handling for _change_state method in K8 Executor

[ https://issues.apache.org/jira/browse/AIRFLOW-4123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799099#comment-16799099 ] ASF subversion and git services commented on AIRFLOW-4123: -- Commit

[jira] [Commented] (AIRFLOW-4009) Fix docstring issue in GoogleCloudStorageToBigQueryOperator

[ https://issues.apache.org/jira/browse/AIRFLOW-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799092#comment-16799092 ] ASF subversion and git services commented on AIRFLOW-4009: -- Commit

[jira] [Commented] (AIRFLOW-2568) Implement a Azure Container Instances operator

[ https://issues.apache.org/jira/browse/AIRFLOW-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799095#comment-16799095 ] ASF subversion and git services commented on AIRFLOW-2568: -- Commit

[GitHub] [airflow] ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268204537 ## File path: airflow/contrib/operators/dingding_webhook_operator.py ## @@ -0,0 +1,73 @@ +# -*- coding:

[GitHub] [airflow] ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268206731 ## File path: airflow/contrib/hooks/dingding_webhook_hook.py ## @@ -0,0 +1,121 @@ +# -*- coding: utf-8

[GitHub] [airflow] ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268210865 ## File path: airflow/utils/db.py ## @@ -286,6 +286,13 @@ def initdb(): Connection(

[GitHub] [airflow] ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268205012 ## File path: airflow/utils/db.py ## @@ -286,6 +286,13 @@ def initdb(): Connection(

[GitHub] [airflow] ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268207768 ## File path: airflow/contrib/hooks/dingding_webhook_hook.py ## @@ -0,0 +1,121 @@ +# -*- coding: utf-8

[GitHub] [airflow] ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268210584 ## File path: airflow/utils/db.py ## @@ -286,6 +286,13 @@ def initdb(): Connection(

[GitHub] [airflow] ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator

ashb commented on a change in pull request #4895: [AIRFLOW-1526] Add dingding hook and operator URL: https://github.com/apache/airflow/pull/4895#discussion_r268203954 ## File path: airflow/contrib/operators/dingding_webhook_operator.py ## @@ -0,0 +1,73 @@ +# -*- coding:

[jira] [Commented] (AIRFLOW-4140) Pause/unpause button not working

[ https://issues.apache.org/jira/browse/AIRFLOW-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799073#comment-16799073 ] ASF GitHub Bot commented on AIRFLOW-4140: - ashb commented on pull request #4958: [AIRFLOW-4140]

[jira] [Commented] (AIRFLOW-3584) Switch dags index view to orm dags

[ https://issues.apache.org/jira/browse/AIRFLOW-3584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799074#comment-16799074 ] ASF subversion and git services commented on AIRFLOW-3584: -- Commit

[GitHub] [airflow] ashb merged pull request #4958: [AIRFLOW-4140] Fix pause/unpause button

ashb merged pull request #4958: [AIRFLOW-4140] Fix pause/unpause button URL: https://github.com/apache/airflow/pull/4958 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [airflow] bryanyang0528 commented on a change in pull request #4919: [AIRFLOW-4093] Throw exception if job failed or cancelled or retry too many times

bryanyang0528 commented on a change in pull request #4919: [AIRFLOW-4093] Throw exception if job failed or cancelled or retry too many times URL: https://github.com/apache/airflow/pull/4919#discussion_r268200430 ## File path: airflow/contrib/operators/aws_athena_operator.py

[GitHub] [airflow] ashb commented on issue #4390: [AIRFLOW-3584] Use ORM DAGs for index view.

ashb commented on issue #4390: [AIRFLOW-3584] Use ORM DAGs for index view. URL: https://github.com/apache/airflow/pull/4390#issuecomment-475646010 So I had cherry-picked this on to v1-10-stable for inclusion in 1.10.3 but I just had a thought: Does this change now mean that dags

  1   2   >