From 727eedc16b00f245f4e2b54a8ee54963c8c5dbd2 Mon Sep 17 00:00:00 2001 From: Dmytro Kazanzhy Date: Fri, 4 Mar 2022 14:30:31 +0200 Subject: [PATCH 1/2] Update `moto` library to version 3.0 --- setup.py | 4 +--- tests/providers/amazon/aws/hooks/test_kinesis.py | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/setup.py b/setup.py index 9a50d69297d89..280f522033c29 100644 --- a/setup.py +++ b/setup.py @@ -619,9 +619,7 @@ def write_version(filename: str = os.path.join(*[my_dir, "airflow", "git_version 'jira', 'jsondiff', 'mongomock', - # Moto3 is limited for unknown reason - # TODO: attempt to remove the limitation - 'moto~=2.2,>=2.2.12', + 'moto~=3.0,>=3.0.3', 'parameterized', 'paramiko', 'pipdeptree', diff --git a/tests/providers/amazon/aws/hooks/test_kinesis.py b/tests/providers/amazon/aws/hooks/test_kinesis.py index f94b87e5aedba..dbad0b45880ef 100644 --- a/tests/providers/amazon/aws/hooks/test_kinesis.py +++ b/tests/providers/amazon/aws/hooks/test_kinesis.py @@ -58,7 +58,7 @@ def test_insert_batch_records_kinesis_firehose(self): ) stream_arn = response['DeliveryStreamARN'] - assert stream_arn == "arn:aws:firehose:us-east-1:123456789012:/delivery_stream/test_airflow" + assert stream_arn == "arn:aws:firehose:us-east-1:123456789012:deliverystream/test_airflow" records = [{"Data": str(uuid.uuid4())} for _ in range(100)] From d2233acd5d8f9f809f47ed0fbf375e733f078575 Mon Sep 17 00:00:00 2001 From: Jarek Potiuk Date: Sat, 5 Mar 2022 17:36:54 +0100 Subject: [PATCH 2/2] Update setup.py --- setup.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/setup.py b/setup.py index 280f522033c29..96c5b4b2d1df7 100644 --- a/setup.py +++ b/setup.py @@ -619,7 +619,7 @@ def write_version(filename: str = os.path.join(*[my_dir, "airflow", "git_version 'jira', 'jsondiff', 'mongomock', - 'moto~=3.0,>=3.0.3', + 'moto>=3.0.3', 'parameterized', 'paramiko', 'pipdeptree',