ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r723681321
##
File path: airflow/providers/amazon/aws/sensors/eks.py
##
@@ -77,6 +82,65 @@ def poke(self, context):
return cluster_state == self.target_s
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r723681321
##
File path: airflow/providers/amazon/aws/sensors/eks.py
##
@@ -77,6 +82,65 @@ def poke(self, context):
return cluster_state == self.target_s
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r722712868
##
File path: airflow/providers/amazon/aws/operators/eks.py
##
@@ -23,25 +23,41 @@
from airflow import AirflowException
from airflow.models import
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r722712632
##
File path: airflow/providers/amazon/aws/operators/eks.py
##
@@ -93,21 +122,42 @@ def __init__(
cluster_name: str,
cluster_role_arn
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r722712363
##
File path: airflow/providers/amazon/aws/operators/eks.py
##
@@ -227,6 +284,78 @@ def execute(self, context):
)
+class EKSCreateFargateP
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r722712072
##
File path: airflow/providers/amazon/aws/operators/eks.py
##
@@ -280,41 +409,83 @@ def execute(self, context):
)
if self.force_de
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r722712001
##
File path: airflow/providers/amazon/aws/operators/eks.py
##
@@ -280,41 +409,83 @@ def execute(self, context):
)
if self.force_de
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r722711594
##
File path: setup.py
##
@@ -513,7 +513,7 @@ def write_version(filename: str = os.path.join(*[my_dir,
"airflow", "git_version
'jira',
'json
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r722711354
##
File path:
airflow/providers/amazon/aws/example_dags/example_eks_with_fargate_profile.py
##
@@ -0,0 +1,124 @@
+# Licensed to the Apache Software Fo
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r722711186
##
File path:
airflow/providers/amazon/aws/example_dags/example_eks_with_nodegroups.py
##
@@ -40,11 +39,15 @@
'endpointPrivateAccess': False,
}
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r719891856
##
File path: airflow/providers/amazon/aws/operators/eks.py
##
@@ -93,21 +122,42 @@ def __init__(
cluster_name: str,
cluster_role_arn
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r720480474
##
File path: airflow/providers/amazon/aws/operators/eks.py
##
@@ -227,6 +284,78 @@ def execute(self, context):
)
+class EKSCreateFargateP
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r720475737
##
File path:
airflow/providers/amazon/aws/example_dags/example_eks_with_fargate_profile.py
##
@@ -0,0 +1,124 @@
+# Licensed to the Apache Software Fo
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r719892210
##
File path: setup.py
##
@@ -513,7 +513,7 @@ def write_version(filename: str = os.path.join(*[my_dir,
"airflow", "git_version
'jira',
'json
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r719891856
##
File path: airflow/providers/amazon/aws/operators/eks.py
##
@@ -93,21 +122,42 @@ def __init__(
cluster_name: str,
cluster_role_arn
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r719891573
##
File path: airflow/providers/amazon/aws/operators/eks.py
##
@@ -154,11 +204,18 @@ def execute(self, context):
subnets=self.resource
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r719886702
##
File path:
airflow/providers/amazon/aws/example_dags/example_eks_with_fargate_in_one_step.py
##
@@ -0,0 +1,100 @@
+# Licensed to the Apache Softwar
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r719886567
##
File path:
airflow/providers/amazon/aws/example_dags/example_eks_with_fargate_in_one_step.py
##
@@ -0,0 +1,100 @@
+# Licensed to the Apache Softwar
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r719746756
##
File path:
airflow/providers/amazon/aws/example_dags/example_eks_with_fargate_in_one_step.py
##
@@ -0,0 +1,100 @@
+# Licensed to the Apache Softwar
ferruzzi commented on a change in pull request #18645:
URL: https://github.com/apache/airflow/pull/18645#discussion_r719637333
##
File path: airflow/providers/amazon/aws/sensors/eks.py
##
@@ -77,6 +82,65 @@ def poke(self, context):
return cluster_state == self.target_s
20 matches
Mail list logo
