diff --git a/setup.py b/setup.py index 9a50d69297d89..96c5b4b2d1df7 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', '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)]