kloczek
commented
1 year ago Here is pytest output:
```console
+ PYTHONPATH=/home/tkloczko/rpmbuild/BUILDROOT/python-aiobotocore-2.4.0-2.fc35.x86_64/usr/lib64/python3.8/site-packages:/home/tkloczko/rpmbuild/BUILDROOT/python-aiobotocore-2.4.0-2.fc35.x86_64/usr/lib/python3.8/site-packages
+ /usr/bin/pytest -ra
=========================================================================== test session starts ============================================================================
platform linux -- Python 3.8.13, pytest-7.1.2, pluggy-1.0.0
rootdir: /home/tkloczko/rpmbuild/BUILD/aiobotocore-2.4.0, configfile: pytest.ini
plugins: asyncio-0.19.0
asyncio: mode=strict
collected 182 items
tests/test_adaptive.py ........... [ 6%]
tests/test_basic_s3.py FFFFFFFFFFFFFFFFEFFFFsFFFFFFFFFF [ 23%]
tests/test_batch.py F [ 23%]
tests/test_config.py ..... [ 26%]
tests/test_dynamodb.py FFFFFF [ 29%]
tests/test_ec2.py F [ 30%]
tests/test_eventstreams.py FF [ 31%]
tests/test_lambda.py F [ 31%]
tests/test_monitor.py F [ 32%]
tests/test_mturk.py F [ 32%]
tests/test_patches.py .F [ 34%]
tests/test_response.py ............... [ 42%]
tests/test_session.py .. [ 43%]
tests/test_sns.py EEEEEEFF [ 46%]
tests/test_sqs.py FFFF [ 48%]
tests/test_version.py . [ 48%]
tests/test_waiter.py F [ 49%]
tests/boto_tests/test_credentials.py ............................FFFEFFF [ 68%]
tests/boto_tests/test_signers.py F [ 69%]
tests/boto_tests/test_utils.py ........ [ 73%]
tests/python3.8/test_eventstreams.py F [ 74%]
tests/python3.8/boto_tests/test_credentials.py ............... [ 82%]
tests/python3.8/boto_tests/test_signers.py ..FFFFFF [ 86%]
tests/python3.8/boto_tests/test_utils.py ........................ [100%]
================================================================================== ERRORS ==================================================================================
_______________________________________________________________ ERROR at teardown of test_paginate_max_items _______________________________________________________________
/usr/lib/python3.8/site-packages/pygments/lexer.py:218: RuntimeWarning: coroutine 'fake_aiohttp_session..FakeAioHttpSession.FakeResponse._text' was never awaited
def __init__(self, _root_lexer, _language_lexer, _needle=Other, **options):
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
def fin():
event_loop.run_until_complete(
> s3_client.abort_multipart_upload(
UploadId=upload_id, Bucket=bucket_name, Key=_key_name
)
)
E AttributeError: 'async_generator' object has no attribute 'abort_multipart_upload'
tests/conftest.py:497: AttributeError
_________________________________________________________________ ERROR at setup of test_topic_attributes __________________________________________________________________
region = 'us-east-1', create_topic = ._f at 0x7f3e25b21820>, sns_client =
event_loop = <_UnixSelectorEventLoop running=False closed=False debug=False>
@pytest.fixture
def topic_arn(region, create_topic, sns_client, event_loop):
> arn = event_loop.run_until_complete(create_topic())
tests/conftest.py:535:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/lib64/python3.8/asyncio/base_events.py:616: in run_until_complete
return future.result()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
async def _f():
nonlocal _topic_arn
> response = await sns_client.create_topic(Name=random_name())
E AttributeError: 'async_generator' object has no attribute 'create_topic'
tests/conftest.py:550: AttributeError
________________________________________________________________ ERROR at teardown of test_topic_attributes ________________________________________________________________
def fin():
> event_loop.run_until_complete(delete_topic(sns_client, _topic_arn))
tests/conftest.py:556:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/lib64/python3.8/asyncio/base_events.py:616: in run_until_complete
return future.result()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
sns_client = , topic_arn = None
async def delete_topic(sns_client, topic_arn):
> response = await sns_client.delete_topic(TopicArn=topic_arn)
E AttributeError: 'async_generator' object has no attribute 'delete_topic'
tests/conftest.py:540: AttributeError
_______________________________________________________________ ERROR at setup of test_creating_subscription _______________________________________________________________
region = 'us-east-1', create_topic = ._f at 0x7f3e252f1160>, sns_client =
event_loop = <_UnixSelectorEventLoop running=False closed=False debug=False>
@pytest.fixture
def topic_arn(region, create_topic, sns_client, event_loop):
> arn = event_loop.run_until_complete(create_topic())
tests/conftest.py:535:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/lib64/python3.8/asyncio/base_events.py:616: in run_until_complete
return future.result()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
async def _f():
nonlocal _topic_arn
> response = await sns_client.create_topic(Name=random_name())
E AttributeError: 'async_generator' object has no attribute 'create_topic'
tests/conftest.py:550: AttributeError
_____________________________________________________________ ERROR at teardown of test_creating_subscription ______________________________________________________________
def fin():
> event_loop.run_until_complete(delete_topic(sns_client, _topic_arn))
tests/conftest.py:556:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/lib64/python3.8/asyncio/base_events.py:616: in run_until_complete
return future.result()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
sns_client = , topic_arn = None
async def delete_topic(sns_client, topic_arn):
> response = await sns_client.delete_topic(TopicArn=topic_arn)
E AttributeError: 'async_generator' object has no attribute 'delete_topic'
tests/conftest.py:540: AttributeError
__________________________________________________________________ ERROR at setup of test_publish_to_http __________________________________________________________________
region = 'us-east-1', create_topic = ._f at 0x7f3e25e75c10>, sns_client =
event_loop = <_UnixSelectorEventLoop running=False closed=False debug=False>
@pytest.fixture
def topic_arn(region, create_topic, sns_client, event_loop):
> arn = event_loop.run_until_complete(create_topic())
tests/conftest.py:535:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/lib64/python3.8/asyncio/base_events.py:616: in run_until_complete
return future.result()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
async def _f():
nonlocal _topic_arn
> response = await sns_client.create_topic(Name=random_name())
E AttributeError: 'async_generator' object has no attribute 'create_topic'
tests/conftest.py:550: AttributeError
________________________________________________________________ ERROR at teardown of test_publish_to_http _________________________________________________________________
def fin():
> event_loop.run_until_complete(delete_topic(sns_client, _topic_arn))
tests/conftest.py:556:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/lib64/python3.8/asyncio/base_events.py:616: in run_until_complete
return future.result()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
sns_client = , topic_arn = None
async def delete_topic(sns_client, topic_arn):
> response = await sns_client.delete_topic(TopicArn=topic_arn)
E AttributeError: 'async_generator' object has no attribute 'delete_topic'
tests/conftest.py:540: AttributeError
________________________________________________________ ERROR at setup of test_load_sso_credentials_without_cache _________________________________________________________
file /home/tkloczko/rpmbuild/BUILD/aiobotocore-2.4.0/tests/boto_tests/test_credentials.py, line 1256
def test_load_sso_credentials_without_cache(self):
E fixture 'self' not found
> available fixtures: aa_fail_proxy_config, aa_succeed_proxy_config, aio_session, alternative_region, alternative_s3_client, assume_role_setup, assumerolecredprovider_config_loader, base_assume_role_test_setup, base_env_var_setup, batch_client, batch_server, bucket_name, cache, capfd, capfdbinary, caplog, capsys, capsysbinary, cloudformation_client, cloudformation_server, config, create_bucket, create_multipart_upload, create_object, create_table, create_topic, credential_provider, debug, doctest_namespace, dynamodb2_server, dynamodb_client, dynamodb_put_item, ec2_client, ec2_server, event_loop, exit_stack, iam_client, iam_server, kinesis_client, kinesis_server, lambda_client, lambda_server, mock_session, mocking_test, monkeypatch, patch_attributes, profile_config, pytestconfig, rds_client, rds_server, record_property, record_testsuite_property, record_xml_attribute, recwarn, region, s3_client, s3_server, s3_verify, session, signature_version, sns_client, sns_server, sqs_client, sqs_queue_url, sqs_server, ssl_credential_fetcher_setup, sso_provider_setup, table_name, tempdir, tmp_path, tmp_path_factory, tmpdir, tmpdir_factory, topic_arn, unused_tcp_port, unused_tcp_port_factory, unused_udp_port, unused_udp_port_factory
> use 'pytest --fixtures [testpath]' for help on them.
/home/tkloczko/rpmbuild/BUILD/aiobotocore-2.4.0/tests/boto_tests/test_credentials.py:1256
================================================================================= FAILURES =================================================================================
__________________________________________________________________________ test_can_make_request ___________________________________________________________________________
s3_client =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_can_make_request(s3_client):
# Basic smoke test to ensure we can talk to s3.
> result = await s3_client.list_buckets()
E AttributeError: 'async_generator' object has no attribute 'list_buckets'
tests/test_basic_s3.py:23: AttributeError
__________________________________________________________________ test_can_make_request_no_verify[False] __________________________________________________________________
s3_client =
@pytest.mark.moto
@pytest.mark.parametrize('s3_verify', [False])
@pytest.mark.asyncio
async def test_can_make_request_no_verify(s3_client):
# Basic smoke test to ensure we can talk to s3.
> result = await s3_client.list_buckets()
E AttributeError: 'async_generator' object has no attribute 'list_buckets'
tests/test_basic_s3.py:35: AttributeError
_________________________________________________________________________ test_fail_proxy_request __________________________________________________________________________
aa_fail_proxy_config = None, s3_client = , monkeypatch = <_pytest.monkeypatch.MonkeyPatch object at 0x7f3e25f7ff10>
@pytest.mark.moto
@pytest.mark.asyncio
async def test_fail_proxy_request(
aa_fail_proxy_config, s3_client, monkeypatch
):
# based on test_can_make_request
with pytest.raises(httpsession.ProxyConnectionError):
> await s3_client.list_buckets()
E AttributeError: 'async_generator' object has no attribute 'list_buckets'
tests/test_basic_s3.py:49: AttributeError
____________________________________________________________________ test_succeed_proxy_request[False] _____________________________________________________________________
aa_succeed_proxy_config = None, s3_client =
@pytest.mark.asyncio
@pytest.mark.parametrize('mocking_test', [False])
async def test_succeed_proxy_request(aa_succeed_proxy_config, s3_client):
> result = await s3_client.list_buckets()
E AttributeError: 'async_generator' object has no attribute 'list_buckets'
tests/test_basic_s3.py:55: AttributeError
_______________________________________________________________________ test_can_get_bucket_location _______________________________________________________________________
s3_client = , bucket_name =
@pytest.mark.asyncio
@pytest.mark.moto
async def test_can_get_bucket_location(s3_client, bucket_name):
> result = await s3_client.get_bucket_location(Bucket=bucket_name)
E AttributeError: 'async_generator' object has no attribute 'get_bucket_location'
tests/test_basic_s3.py:63: AttributeError
____________________________________________________________________ test_can_delete_urlencoded_object _____________________________________________________________________
s3_client = , bucket_name =
create_object = ._f at 0x7f3e25cd1940>
@pytest.mark.moto
@pytest.mark.asyncio
async def test_can_delete_urlencoded_object(
s3_client, bucket_name, create_object
):
key_name = 'a+b/foo'
> await create_object(key_name=key_name)
tests/test_basic_s3.py:76:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'a+b/foo', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
____________________________________________________________________________ test_can_paginate _____________________________________________________________________________
s3_client = , bucket_name =
create_object = ._f at 0x7f3e25cd1ca0>
@pytest.mark.asyncio
@pytest.mark.moto
async def test_can_paginate(s3_client, bucket_name, create_object):
for i in range(5):
key_name = 'key%s' % i
> await create_object(key_name)
tests/test_basic_s3.py:97:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'key0', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
_____________________________________________________________________ test_can_paginate_with_page_size _____________________________________________________________________
s3_client = , bucket_name =
create_object = ._f at 0x7f3e25e97310>
@pytest.mark.asyncio
@pytest.mark.moto
async def test_can_paginate_with_page_size(
s3_client, bucket_name, create_object
):
for i in range(5):
key_name = 'key%s' % i
> await create_object(key_name)
tests/test_basic_s3.py:115:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'key0', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
_________________________________________________________________________ test_can_search_paginate _________________________________________________________________________
s3_client = , bucket_name =
create_object = ._f at 0x7f3e25e97550>
@pytest.mark.asyncio
@pytest.mark.moto
async def test_can_search_paginate(s3_client, bucket_name, create_object):
keys = []
for i in range(5):
key_name = 'key%s' % i
keys.append(key_name)
> await create_object(key_name)
tests/test_basic_s3.py:136:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'key0', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
________________________________________________________________________ test_can_paginate_iterator ________________________________________________________________________
s3_client = , bucket_name =
create_object = ._f at 0x7f3e25e351f0>
@pytest.mark.asyncio
@pytest.mark.moto
async def test_can_paginate_iterator(s3_client, bucket_name, create_object):
for i in range(5):
key_name = 'key%s' % i
> await create_object(key_name)
tests/test_basic_s3.py:149:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'key0', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
__________________________________________________________________________ test_result_key_iters ___________________________________________________________________________
s3_client = , bucket_name =
create_object = ._f at 0x7f3e25cd1dc0>
@pytest.mark.asyncio
@pytest.mark.moto
async def test_result_key_iters(s3_client, bucket_name, create_object):
for i in range(5):
key_name = f'key/{i}/{i}'
> await create_object(key_name)
tests/test_basic_s3.py:169:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'key/0/0', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
_______________________________________________________________________ test_can_get_and_put_object ________________________________________________________________________
s3_client = , create_object = ._f at 0x7f3e25cd1f70>
bucket_name =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_can_get_and_put_object(s3_client, create_object, bucket_name):
> await create_object('foobarbaz', body='body contents')
tests/test_basic_s3.py:198:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'foobarbaz', body = 'body contents'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
___________________________________________________________________________ test_adaptive_retry ____________________________________________________________________________
s3_client = , config =
create_object = ._f at 0x7f3e25e35af0>, bucket_name =
patch_attributes = [, , , ]
@pytest.mark.moto
@pytest.mark.asyncio
@pytest.mark.patch_attributes(
[
dict(
target="aiobotocore.retries.adaptive.AsyncClientRateLimiter.on_sending_request",
side_effect=aiobotocore.retries.adaptive.AsyncClientRateLimiter.on_sending_request,
autospec=True,
),
dict(
target="aiobotocore.retries.adaptive.AsyncClientRateLimiter.on_receiving_response",
side_effect=aiobotocore.retries.adaptive.AsyncClientRateLimiter.on_receiving_response,
autospec=True,
),
dict(
target="botocore.retries.adaptive.ClientRateLimiter.on_sending_request",
side_effect=botocore.retries.adaptive.ClientRateLimiter.on_sending_request,
autospec=True,
),
dict(
target="botocore.retries.adaptive.ClientRateLimiter.on_receiving_response",
side_effect=botocore.retries.adaptive.ClientRateLimiter.on_receiving_response,
autospec=True,
),
]
)
@pytest.mark.config_kwargs(
dict(retries={"max_attempts": 5, "mode": "adaptive"})
)
async def test_adaptive_retry(
s3_client, config, create_object, bucket_name, patch_attributes
):
> await create_object('foobarbaz', body='body contents')
tests/test_basic_s3.py:238:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'foobarbaz', body = 'body contents'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
______________________________________________________________________ test_get_object_stream_wrapper ______________________________________________________________________
s3_client = , create_object = ._f at 0x7f3e25c61550>
bucket_name =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_get_object_stream_wrapper(
s3_client, create_object, bucket_name
):
> await create_object('foobarbaz', body='body contents')
tests/test_basic_s3.py:265:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'foobarbaz', body = 'body contents'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
______________________________________________________________________ test_get_object_stream_context ______________________________________________________________________
s3_client = , create_object = ._f at 0x7f3e25c611f0>
bucket_name =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_get_object_stream_context(
s3_client, create_object, bucket_name
):
> await create_object('foobarbaz', body='body contents')
tests/test_basic_s3.py:280:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'foobarbaz', body = 'body contents'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
_________________________________________________________________________ test_paginate_max_items __________________________________________________________________________
s3_client = , create_multipart_upload = ._f at 0x7f3e25e94160>
bucket_name =
@pytest.mark.asyncio
@pytest.mark.moto
async def test_paginate_max_items(
s3_client, create_multipart_upload, bucket_name
):
> await create_multipart_upload('foo/key1')
tests/test_basic_s3.py:291:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'foo/key1'
async def _f(key_name):
nonlocal _key_name
nonlocal upload_id
_key_name = key_name
> parsed = await s3_client.create_multipart_upload(
Bucket=bucket_name, Key=key_name
)
E AttributeError: 'async_generator' object has no attribute 'create_multipart_upload'
tests/conftest.py:489: AttributeError
___________________________________________________________________ test_paginate_within_page_boundaries ___________________________________________________________________
s3_client = , create_object = ._f at 0x7f3e25e94c10>
bucket_name =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_paginate_within_page_boundaries(
s3_client, create_object, bucket_name
):
> await create_object('a')
tests/test_basic_s3.py:332:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'a', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
_____________________________________________________________________ test_unicode_key_put_list[False] _____________________________________________________________________
s3_client = , bucket_name =
create_object = ._f at 0x7f3e25d703a0>
@pytest.mark.asyncio
@pytest.mark.parametrize('mocking_test', [False])
async def test_unicode_key_put_list(s3_client, bucket_name, create_object):
# Verify we can upload a key with a unicode char and list it as well.
key_name = '\u2713'
> await create_object(key_name)
tests/test_basic_s3.py:376:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = '✓', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
___________________________________________________________________ test_unicode_system_character[False] ___________________________________________________________________
s3_client = , bucket_name =
create_object = ._f at 0x7f3e25d705e0>
@pytest.mark.asyncio
@pytest.mark.parametrize('mocking_test', [False])
async def test_unicode_system_character(s3_client, bucket_name, create_object):
# Verify we can use a unicode system character which would normally
# break the xml parser
key_name = 'foo\x08'
> await create_object(key_name)
tests/test_basic_s3.py:392:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'foo\x08', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
______________________________________________________________________ test_non_normalized_key_paths _______________________________________________________________________
s3_client = , bucket_name =
create_object = ._f at 0x7f3e25c619d0>
@pytest.mark.moto
@pytest.mark.asyncio
async def test_non_normalized_key_paths(s3_client, bucket_name, create_object):
# The create_object method has assertEqual checks for 200 status.
> await create_object('key./././name')
tests/test_basic_s3.py:408:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'key./././name', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
________________________________________________________________________ test_copy_with_quoted_char ________________________________________________________________________
s3_client = , create_object = ._f at 0x7f3e25c615e0>
bucket_name =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_copy_with_quoted_char(s3_client, create_object, bucket_name):
key_name = 'a+b/foo'
> await create_object(key_name=key_name)
tests/test_basic_s3.py:428:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'a+b/foo', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
_______________________________________________________________________ test_copy_with_query_string ________________________________________________________________________
s3_client = , create_object = ._f at 0x7f3e25d99040>
bucket_name =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_copy_with_query_string(s3_client, create_object, bucket_name):
key_name = 'a+b/foo?notVersionid=bar'
> await create_object(key_name=key_name)
tests/test_basic_s3.py:447:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'a+b/foo?notVersionid=bar', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
_______________________________________________________________________ test_can_copy_with_dict_form _______________________________________________________________________
s3_client = , create_object = ._f at 0x7f3e25e35700>
bucket_name =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_can_copy_with_dict_form(s3_client, create_object, bucket_name):
key_name = 'a+b/foo?versionId=abcd'
> await create_object(key_name=key_name)
tests/test_basic_s3.py:467:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'a+b/foo?versionId=abcd', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
________________________________________________________________ test_can_copy_with_dict_form_with_version _________________________________________________________________
s3_client = , create_object = ._f at 0x7f3e25cd1af0>
bucket_name =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_can_copy_with_dict_form_with_version(
s3_client, create_object, bucket_name
):
key_name = 'a+b/foo?versionId=abcd'
> response = await create_object(key_name=key_name)
tests/test_basic_s3.py:489:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'a+b/foo?versionId=abcd', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
________________________________________________________________________ test_copy_with_s3_metadata ________________________________________________________________________
s3_client = , create_object = ._f at 0x7f3e25cd1790>
bucket_name =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_copy_with_s3_metadata(s3_client, create_object, bucket_name):
key_name = 'foo.txt'
> await create_object(key_name=key_name)
tests/test_basic_s3.py:512:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'foo.txt', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
____________________________________________________ test_presign_with_existing_query_string_values[False-s3-us-east-1] ____________________________________________________
s3_client = , bucket_name =
aio_session = , create_object = ._f at 0x7f3e25e97ee0>
@pytest.mark.parametrize('region', ['us-east-1'])
@pytest.mark.parametrize('signature_version', ['s3'])
# 'Content-Disposition' not supported by moto yet
@pytest.mark.parametrize('mocking_test', [False])
@pytest.mark.asyncio
async def test_presign_with_existing_query_string_values(
s3_client, bucket_name, aio_session, create_object
):
key_name = 'foo.txt'
> await create_object(key_name=key_name)
tests/test_basic_s3.py:533:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'foo.txt', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
_________________________________________________________________ test_presign_sigv4[False-s3v4-us-east-1] _________________________________________________________________
s3_client = , bucket_name =
aio_session = , create_object = ._f at 0x7f3e25e97f70>
@pytest.mark.parametrize('region', ['us-east-1'])
@pytest.mark.parametrize('signature_version', ['s3v4'])
# moto host will be localhost
@pytest.mark.parametrize('mocking_test', [False])
@pytest.mark.asyncio
async def test_presign_sigv4(
s3_client, bucket_name, aio_session, create_object
):
key = 'myobject'
> await create_object(key_name=key)
tests/test_basic_s3.py:560:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'myobject', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
_____________________________________________________________ test_can_follow_signed_url_redirect[False-s3v4] ______________________________________________________________
alternative_s3_client = , create_object = ._f at 0x7f3e25d70b80>
bucket_name =
@pytest.mark.parametrize('signature_version', ['s3v4'])
@pytest.mark.parametrize('mocking_test', [False])
@pytest.mark.asyncio
async def test_can_follow_signed_url_redirect(
alternative_s3_client, create_object, bucket_name
):
> await create_object('foobarbaz')
tests/test_basic_s3.py:584:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'foobarbaz', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
_____________________________________________________________ test_bucket_redirect[False-us-west-2-eu-west-1] ______________________________________________________________
s3_client = , alternative_s3_client =
region = 'eu-west-1', create_bucket =
@pytest.mark.parametrize('region', ['eu-west-1'])
@pytest.mark.parametrize('alternative_region', ['us-west-2'])
@pytest.mark.parametrize('mocking_test', [False])
@pytest.mark.asyncio
async def test_bucket_redirect(
s3_client, alternative_s3_client, region, create_bucket
):
key = 'foobarbaz'
# create bucket in alternative region
> bucket_name = await create_bucket(region)
E TypeError: 'async_generator' object is not callable
tests/test_basic_s3.py:605: TypeError
_______________________________________________________________________ test_head_object_keys[s3v4] ________________________________________________________________________
s3_client = , create_object = ._f at 0x7f3e25e35dc0>
bucket_name =
@pytest.mark.parametrize('signature_version', ['s3v4'])
@pytest.mark.asyncio
@pytest.mark.moto
async def test_head_object_keys(s3_client, create_object, bucket_name):
> await create_object('foobarbaz')
tests/test_basic_s3.py:621:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_name = 'foobarbaz', body = 'foo'
async def _f(key_name, body='foo'):
> r = await s3_client.put_object(
Bucket=bucket_name, Key=key_name, Body=body
)
E AttributeError: 'async_generator' object has no attribute 'put_object'
tests/conftest.py:470: AttributeError
________________________________________________________________________________ test_batch ________________________________________________________________________________
batch_client =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_batch(batch_client):
> job_queues = await batch_client.describe_job_queues()
E AttributeError: 'async_generator' object has no attribute 'describe_job_queues'
tests/test_batch.py:7: AttributeError
____________________________________________________________________________ test_get_item[v4] _____________________________________________________________________________
dynamodb_client = , table_name =
dynamodb_put_item = ._f at 0x7f3e2500e670>
@pytest.mark.moto
@pytest.mark.parametrize('signature_version', ['v4'])
@pytest.mark.asyncio
async def test_get_item(dynamodb_client, table_name, dynamodb_put_item):
test_value = 'testValue'
> await dynamodb_put_item(test_value)
tests/test_dynamodb.py:32:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
key_string_value = 'testValue'
async def _f(key_string_value):
> response = await dynamodb_client.put_item(
TableName=table_name,
Item={'testKey': {'S': key_string_value}},
)
E AttributeError: 'async_generator' object has no attribute 'put_item'
tests/conftest.py:524: AttributeError
__________________________________________________________________________ test_create_waiter[v4] __________________________________________________________________________
dynamodb_client =
dynamodb_table_def = {'AttributeDefinitions': [{'AttributeName': 'testKey', 'AttributeType': 'N'}], 'KeySchema': [{'AttributeName': 'testKe...nedThroughput': {'ReadCapacityUnits': 1, 'WriteCapacityUnits': 1}, 'TableName': 'cf5179d6-7603-44e9-994d-fc4b448683d6'}
@pytest.mark.moto
@pytest.mark.parametrize('signature_version', ['v4'])
@pytest.mark.asyncio
async def test_create_waiter(dynamodb_client, dynamodb_table_def):
table_name = dynamodb_table_def['TableName']
> response = await dynamodb_client.create_table(**dynamodb_table_def)
E AttributeError: 'async_generator' object has no attribute 'create_table'
tests/test_dynamodb.py:46: AttributeError
________________________________________________________________________ test_batch_write_scan[v4] _________________________________________________________________________
dynamodb_client = , table_name =
@pytest.mark.moto
@pytest.mark.parametrize('signature_version', ['v4'])
@pytest.mark.asyncio
async def test_batch_write_scan(dynamodb_client, table_name):
> response = await dynamodb_client.batch_write_item(
RequestItems={
table_name: [
{
'PutRequest': {
'Item': {
'testKey': {'S': 'key1'},
'testKey2': {'S': 'key2'},
}
}
},
{
'PutRequest': {
'Item': {
'testKey': {'S': 'key3'},
'testKey2': {'S': 'key4'},
}
}
},
]
}
)
E AttributeError: 'async_generator' object has no attribute 'batch_write_item'
tests/test_dynamodb.py:61: AttributeError
__________________________________________________________________________ test_delete_table[v4] ___________________________________________________________________________
dynamodb_client =
dynamodb_table_def = {'AttributeDefinitions': [{'AttributeName': 'testKey', 'AttributeType': 'N'}], 'KeySchema': [{'AttributeName': 'testKe...nedThroughput': {'ReadCapacityUnits': 1, 'WriteCapacityUnits': 1}, 'TableName': '57a5f6ab-da7e-41d5-845a-abefba34eb04'}
@pytest.mark.moto
@pytest.mark.parametrize('signature_version', ['v4'])
@pytest.mark.asyncio
async def test_delete_table(dynamodb_client, dynamodb_table_def):
table_name = dynamodb_table_def['TableName']
> await dynamodb_client.create_table(**dynamodb_table_def)
E AttributeError: 'async_generator' object has no attribute 'create_table'
tests/test_dynamodb.py:98: AttributeError
___________________________________________________________________ test_waiter_table_exists_failure[v4] ___________________________________________________________________
dynamodb_client =
@pytest.mark.moto
@pytest.mark.parametrize('signature_version', ['v4'])
@pytest.mark.asyncio
async def test_waiter_table_exists_failure(dynamodb_client):
> waiter = dynamodb_client.get_waiter('table_exists')
E AttributeError: 'async_generator' object has no attribute 'get_waiter'
tests/test_dynamodb.py:114: AttributeError
_______________________________________________________________________ test_waiter_table_exists[v4] _______________________________________________________________________
event_loop = <_UnixSelectorEventLoop running=False closed=False debug=False>, dynamodb_client =
dynamodb_table_def = {'AttributeDefinitions': [{'AttributeName': 'testKey', 'AttributeType': 'N'}], 'KeySchema': [{'AttributeName': 'testKe...nedThroughput': {'ReadCapacityUnits': 1, 'WriteCapacityUnits': 1}, 'TableName': '9fd3455d-5857-4f83-8b94-7f629ac3eee6'}
@pytest.mark.moto
@pytest.mark.parametrize('signature_version', ['v4'])
@pytest.mark.asyncio
async def test_waiter_table_exists(
event_loop, dynamodb_client, dynamodb_table_def
):
table_name = dynamodb_table_def['TableName']
async def _create_table():
await asyncio.sleep(2)
await dynamodb_client.create_table(**dynamodb_table_def)
task = event_loop.create_task(_create_table())
assert not task.done()
> waiter = dynamodb_client.get_waiter('table_exists')
E AttributeError: 'async_generator' object has no attribute 'get_waiter'
tests/test_dynamodb.py:138: AttributeError
____________________________________________________________________________ test_ec2_snapshot _____________________________________________________________________________
ec2_client =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_ec2_snapshot(ec2_client):
# TODO: this needs to somehow validate the presigned url sent because moto is not
> volume_response = await ec2_client.create_volume(
AvailabilityZone="us-east-1", Size=10
)
E AttributeError: 'async_generator' object has no attribute 'create_volume'
tests/test_ec2.py:8: AttributeError
________________________________________________________________________ test_eventstream_chunking _________________________________________________________________________
s3_client =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_eventstream_chunking(s3_client):
# These are the options passed to the EventStream class
# during a normal run with botocore.
operation_name = 'SelectObjectContent'
> outputshape = s3_client._service_model.operation_model(
operation_name
).output_shape.members['Payload']
E AttributeError: 'async_generator' object has no attribute '_service_model'
tests/test_eventstreams.py:52: AttributeError
_________________________________________________________________________ test_eventstream_no_iter _________________________________________________________________________
s3_client =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_eventstream_no_iter(s3_client):
# These are the options passed to the EventStream class
# during a normal run with botocore.
operation_name = 'SelectObjectContent'
> outputshape = s3_client._service_model.operation_model(
operation_name
).output_shape.members['Payload']
E AttributeError: 'async_generator' object has no attribute '_service_model'
tests/test_eventstreams.py:83: AttributeError
_____________________________________________________________________________ test_run_lambda ______________________________________________________________________________
iam_client = , lambda_client =
aws_lambda_zip = b'PK\x03\x04\x14\x00\x00\x00\x08\x00\x80c\x19U*\x12\x1c6c\x00\x00\x00p\x00\x00\x00\x12\x00\x00\x00lambda_function.py%\...0\x01\x00\x00\x00\x00lambda_function.pyPK\x05\x06\x00\x00\x00\x00\x01\x00\x01\x00@\x00\x00\x00\x93\x00\x00\x00\x00\x00'
@pytest.mark.moto
@pytest.mark.asyncio
async def test_run_lambda(iam_client, lambda_client, aws_lambda_zip):
> role_arn = await _get_role_arn(iam_client, 'test-iam-role')
tests/test_lambda.py:47:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
iam_client = , role_name = 'test-iam-role'
async def _get_role_arn(iam_client, role_name: str):
try:
> response = await iam_client.get_role(RoleName=role_name)
E AttributeError: 'async_generator' object has no attribute 'get_role'
tests/test_lambda.py:13: AttributeError
______________________________________________________________________ test_monitor_response_received ______________________________________________________________________
session = , s3_client =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_monitor_response_received(session: AioSession, s3_client):
# Basic smoke test to ensure we can talk to s3.
handler_kwargs = {}
def handler(**kwargs):
nonlocal handler_kwargs
handler_kwargs = kwargs
> s3_client.meta.events.register('response-received.s3.ListBuckets', handler)
E AttributeError: 'async_generator' object has no attribute 'meta'
tests/test_monitor.py:16: AttributeError
____________________________________________________________________________ test_mturk_stubber ____________________________________________________________________________
self = , req =
timeout = ClientTimeout(total=None, connect=None, sock_read=1, sock_connect=1), client_error =
args = (functools.partial(, loop=<_UnixSelectorEventLoop running=False closed=False debug=False>), '169.254.169.254', 80)
kwargs = {'family': 0, 'flags': 0, 'local_addr': None, 'proto': 0, ...}
async def _wrap_create_connection(
self,
*args: Any,
req: "ClientRequest",
timeout: "ClientTimeout",
client_error: Type[Exception] = ClientConnectorError,
**kwargs: Any,
) -> Tuple[asyncio.Transport, ResponseHandler]:
try:
async with ceil_timeout(timeout.sock_connect):
> return await self._loop.create_connection(*args, **kwargs) # type: ignore[return-value] # noqa
/usr/lib64/python3.8/site-packages/aiohttp/connector.py:986:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <_UnixSelectorEventLoop running=False closed=False debug=False>
protocol_factory = functools.partial(, loop=<_UnixSelectorEventLoop running=False closed=False debug=False>)
host = '169.254.169.254', port = 80
async def create_connection(
self, protocol_factory, host=None, port=None,
*, ssl=None, family=0,
proto=0, flags=0, sock=None,
local_addr=None, server_hostname=None,
ssl_handshake_timeout=None,
happy_eyeballs_delay=None, interleave=None):
"""Connect to a TCP server.
Create a streaming transport connection to a given Internet host and
port: socket family AF_INET or socket.AF_INET6 depending on host (or
family if specified), socket type SOCK_STREAM. protocol_factory must be
a callable returning a protocol instance.
This method is a coroutine which will try to establish the connection
in the background. When successful, the coroutine returns a
(transport, protocol) pair.
"""
if server_hostname is not None and not ssl:
raise ValueError('server_hostname is only meaningful with ssl')
if server_hostname is None and ssl:
# Use host as default for server_hostname. It is an error
# if host is empty or not set, e.g. when an
# already-connected socket was passed or when only a port
# is given. To avoid this error, you can pass
# server_hostname='' -- this will bypass the hostname
# check. (This also means that if host is a numeric
# IP/IPv6 address, we will attempt to verify that exact
# address; this will probably fail, but it is possible to
# create a certificate for a specific IP address, so we
# don't judge it here.)
if not host:
raise ValueError('You must set server_hostname '
'when using ssl without a host')
server_hostname = host
if ssl_handshake_timeout is not None and not ssl:
raise ValueError(
'ssl_handshake_timeout is only meaningful with ssl')
if happy_eyeballs_delay is not None and interleave is None:
# If using happy eyeballs, default to interleave addresses by family
interleave = 1
if host is not None or port is not None:
if sock is not None:
raise ValueError(
'host/port and sock can not be specified at the same time')
infos = await self._ensure_resolved(
(host, port), family=family,
type=socket.SOCK_STREAM, proto=proto, flags=flags, loop=self)
if not infos:
raise OSError('getaddrinfo() returned empty list')
if local_addr is not None:
laddr_infos = await self._ensure_resolved(
local_addr, family=family,
type=socket.SOCK_STREAM, proto=proto,
flags=flags, loop=self)
if not laddr_infos:
raise OSError('getaddrinfo() returned empty list')
else:
laddr_infos = None
if interleave:
infos = _interleave_addrinfos(infos, interleave)
exceptions = []
if happy_eyeballs_delay is None:
# not using happy eyeballs
for addrinfo in infos:
try:
> sock = await self._connect_sock(
exceptions, addrinfo, laddr_infos)
/usr/lib64/python3.8/asyncio/base_events.py:1010:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <_UnixSelectorEventLoop running=False closed=False debug=False>, exceptions = [[]]
addr_info = (, , 6, '', ('169.254.169.254', 80)), local_addr_infos = None
async def _connect_sock(self, exceptions, addr_info, local_addr_infos=None):
"""Create, bind and connect one socket."""
my_exceptions = []
exceptions.append(my_exceptions)
family, type_, proto, _, address = addr_info
sock = None
try:
sock = socket.socket(family=family, type=type_, proto=proto)
sock.setblocking(False)
if local_addr_infos is not None:
for _, _, _, _, laddr in local_addr_infos:
try:
sock.bind(laddr)
break
except OSError as exc:
msg = (
f'error while attempting to bind on '
f'address {laddr!r}: '
f'{exc.strerror.lower()}'
)
exc = OSError(exc.errno, msg)
my_exceptions.append(exc)
else: # all bind attempts failed
raise my_exceptions.pop()
> await self.sock_connect(sock, address)
/usr/lib64/python3.8/asyncio/base_events.py:924:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <_UnixSelectorEventLoop running=False closed=False debug=False>
sock = , address = ('169.254.169.254', 80)
async def sock_connect(self, sock, address):
"""Connect to a remote socket at address.
This method is a coroutine.
"""
_check_ssl_socket(sock)
if self._debug and sock.gettimeout() != 0:
raise ValueError("the socket must be non-blocking")
if not hasattr(socket, 'AF_UNIX') or sock.family != socket.AF_UNIX:
resolved = await self._ensure_resolved(
address, family=sock.family, proto=sock.proto, loop=self)
_, _, _, _, address = resolved[0]
fut = self.create_future()
self._sock_connect(fut, sock, address)
> return await fut
E asyncio.exceptions.CancelledError
/usr/lib64/python3.8/asyncio/selector_events.py:496: CancelledError
During handling of the above exception, another exception occurred:
self = , method = 'PUT', str_or_url = URL('http://169.254.169.254/latest/api/token')
async def _request(
self,
method: str,
str_or_url: StrOrURL,
*,
params: Optional[Mapping[str, str]] = None,
data: Any = None,
json: Any = None,
cookies: Optional[LooseCookies] = None,
headers: Optional[LooseHeaders] = None,
skip_auto_headers: Optional[Iterable[str]] = None,
auth: Optional[BasicAuth] = None,
allow_redirects: bool = True,
max_redirects: int = 10,
compress: Optional[str] = None,
chunked: Optional[bool] = None,
expect100: bool = False,
raise_for_status: Optional[bool] = None,
read_until_eof: bool = True,
proxy: Optional[StrOrURL] = None,
proxy_auth: Optional[BasicAuth] = None,
timeout: Union[ClientTimeout, object] = sentinel,
verify_ssl: Optional[bool] = None,
fingerprint: Optional[bytes] = None,
ssl_context: Optional[SSLContext] = None,
ssl: Optional[Union[SSLContext, bool, Fingerprint]] = None,
proxy_headers: Optional[LooseHeaders] = None,
trace_request_ctx: Optional[SimpleNamespace] = None,
read_bufsize: Optional[int] = None,
) -> ClientResponse:
# NOTE: timeout clamps existing connect and read timeouts. We cannot
# set the default to None because we need to detect if the user wants
# to use the existing timeouts by setting timeout to None.
if self.closed:
raise RuntimeError("Session is closed")
ssl = _merge_ssl_params(ssl, verify_ssl, ssl_context, fingerprint)
if data is not None and json is not None:
raise ValueError(
"data and json parameters can not be used at the same time"
)
elif json is not None:
data = payload.JsonPayload(json, dumps=self._json_serialize)
if not isinstance(chunked, bool) and chunked is not None:
warnings.warn("Chunk size is deprecated #1615", DeprecationWarning)
redirects = 0
history = []
version = self._version
# Merge with default headers and transform to CIMultiDict
headers = self._prepare_headers(headers)
proxy_headers = self._prepare_headers(proxy_headers)
try:
url = self._build_url(str_or_url)
except ValueError as e:
raise InvalidURL(str_or_url) from e
skip_headers = set(self._skip_auto_headers)
if skip_auto_headers is not None:
for i in skip_auto_headers:
skip_headers.add(istr(i))
if proxy is not None:
try:
proxy = URL(proxy)
except ValueError as e:
raise InvalidURL(proxy) from e
if timeout is sentinel:
real_timeout = self._timeout # type: ClientTimeout
else:
if not isinstance(timeout, ClientTimeout):
real_timeout = ClientTimeout(total=timeout) # type: ignore[arg-type]
else:
real_timeout = timeout
# timeout is cumulative for all request operations
# (request, redirects, responses, data consuming)
tm = TimeoutHandle(self._loop, real_timeout.total)
handle = tm.start()
if read_bufsize is None:
read_bufsize = self._read_bufsize
traces = [
Trace(
self,
trace_config,
trace_config.trace_config_ctx(trace_request_ctx=trace_request_ctx),
)
for trace_config in self._trace_configs
]
for trace in traces:
await trace.send_request_start(method, url.update_query(params), headers)
timer = tm.timer()
try:
with timer:
while True:
url, auth_from_url = strip_auth_from_url(url)
if auth and auth_from_url:
raise ValueError(
"Cannot combine AUTH argument with "
"credentials encoded in URL"
)
if auth is None:
auth = auth_from_url
if auth is None:
auth = self._default_auth
# It would be confusing if we support explicit
# Authorization header with auth argument
if (
headers is not None
and auth is not None
and hdrs.AUTHORIZATION in headers
):
raise ValueError(
"Cannot combine AUTHORIZATION header "
"with AUTH argument or credentials "
"encoded in URL"
)
all_cookies = self._cookie_jar.filter_cookies(url)
if cookies is not None:
tmp_cookie_jar = CookieJar()
tmp_cookie_jar.update_cookies(cookies)
req_cookies = tmp_cookie_jar.filter_cookies(url)
if req_cookies:
all_cookies.load(req_cookies)
if proxy is not None:
proxy = URL(proxy)
elif self._trust_env:
with suppress(LookupError):
proxy, proxy_auth = get_env_proxy_for_url(url)
req = self._request_class(
method,
url,
params=params,
headers=headers,
skip_auto_headers=skip_headers,
data=data,
cookies=all_cookies,
auth=auth,
version=version,
compress=compress,
chunked=chunked,
expect100=expect100,
loop=self._loop,
response_class=self._response_class,
proxy=proxy,
proxy_auth=proxy_auth,
timer=timer,
session=self,
ssl=ssl,
proxy_headers=proxy_headers,
traces=traces,
)
# connection timeout
try:
async with ceil_timeout(real_timeout.connect):
assert self._connector is not None
> conn = await self._connector.connect(
req, traces=traces, timeout=real_timeout
)
/usr/lib64/python3.8/site-packages/aiohttp/client.py:535:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , req = , traces = []
timeout = ClientTimeout(total=None, connect=None, sock_read=1, sock_connect=1)
async def connect(
self, req: "ClientRequest", traces: List["Trace"], timeout: "ClientTimeout"
) -> Connection:
"""Get from pool or create new connection."""
key = req.connection_key
available = self._available_connections(key)
# Wait if there are no available connections or if there are/were
# waiters (i.e. don't steal connection from a waiter about to wake up)
if available <= 0 or key in self._waiters:
fut = self._loop.create_future()
# This connection will now count towards the limit.
self._waiters[key].append(fut)
if traces:
for trace in traces:
await trace.send_connection_queued_start()
try:
await fut
except BaseException as e:
if key in self._waiters:
# remove a waiter even if it was cancelled, normally it's
# removed when it's notified
try:
self._waiters[key].remove(fut)
except ValueError: # fut may no longer be in list
pass
raise e
finally:
if key in self._waiters and not self._waiters[key]:
del self._waiters[key]
if traces:
for trace in traces:
await trace.send_connection_queued_end()
proto = self._get(key)
if proto is None:
placeholder = cast(ResponseHandler, _TransportPlaceholder())
self._acquired.add(placeholder)
self._acquired_per_host[key].add(placeholder)
if traces:
for trace in traces:
await trace.send_connection_create_start()
try:
> proto = await self._create_connection(req, traces, timeout)
/usr/lib64/python3.8/site-packages/aiohttp/connector.py:542:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , req = , traces = []
timeout = ClientTimeout(total=None, connect=None, sock_read=1, sock_connect=1)
async def _create_connection(
self, req: "ClientRequest", traces: List["Trace"], timeout: "ClientTimeout"
) -> ResponseHandler:
"""Create connection.
Has same keyword arguments as BaseEventLoop.create_connection.
"""
if req.proxy:
_, proto = await self._create_proxy_connection(req, traces, timeout)
else:
> _, proto = await self._create_direct_connection(req, traces, timeout)
/usr/lib64/python3.8/site-packages/aiohttp/connector.py:907:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , req = , traces = []
timeout = ClientTimeout(total=None, connect=None, sock_read=1, sock_connect=1)
async def _create_direct_connection(
self,
req: "ClientRequest",
traces: List["Trace"],
timeout: "ClientTimeout",
*,
client_error: Type[Exception] = ClientConnectorError,
) -> Tuple[asyncio.Transport, ResponseHandler]:
sslcontext = self._get_ssl_context(req)
fingerprint = self._get_fingerprint(req)
host = req.url.raw_host
assert host is not None
port = req.port
assert port is not None
host_resolved = asyncio.ensure_future(
self._resolve_host(host, port, traces=traces), loop=self._loop
)
try:
# Cancelling this lookup should not cancel the underlying lookup
# or else the cancel event will get broadcast to all the waiters
# across all connections.
hosts = await asyncio.shield(host_resolved)
except asyncio.CancelledError:
def drop_exception(fut: "asyncio.Future[List[Dict[str, Any]]]") -> None:
with suppress(Exception, asyncio.CancelledError):
fut.result()
host_resolved.add_done_callback(drop_exception)
raise
except OSError as exc:
# in case of proxy it is not ClientProxyConnectionError
# it is problem of resolving proxy ip itself
raise ClientConnectorError(req.connection_key, exc) from exc
last_exc = None # type: Optional[Exception]
for hinfo in hosts:
host = hinfo["host"]
port = hinfo["port"]
try:
> transp, proto = await self._wrap_create_connection(
self._factory,
host,
port,
timeout=timeout,
ssl=sslcontext,
family=hinfo["family"],
proto=hinfo["proto"],
flags=hinfo["flags"],
server_hostname=hinfo["hostname"] if sslcontext else None,
local_addr=self._local_addr,
req=req,
client_error=client_error,
)
/usr/lib64/python3.8/site-packages/aiohttp/connector.py:1175:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , req =
timeout = ClientTimeout(total=None, connect=None, sock_read=1, sock_connect=1), client_error =
args = (functools.partial(, loop=<_UnixSelectorEventLoop running=False closed=False debug=False>), '169.254.169.254', 80)
kwargs = {'family': 0, 'flags': 0, 'local_addr': None, 'proto': 0, ...}
async def _wrap_create_connection(
self,
*args: Any,
req: "ClientRequest",
timeout: "ClientTimeout",
client_error: Type[Exception] = ClientConnectorError,
**kwargs: Any,
) -> Tuple[asyncio.Transport, ResponseHandler]:
try:
async with ceil_timeout(timeout.sock_connect):
> return await self._loop.create_connection(*args, **kwargs) # type: ignore[return-value] # noqa
/usr/lib64/python3.8/site-packages/aiohttp/connector.py:986:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , exc_type = , exc_val = CancelledError()
exc_tb =
async def __aexit__(
self,
exc_type: Optional[Type[BaseException]],
exc_val: Optional[BaseException],
exc_tb: Optional[TracebackType],
) -> Optional[bool]:
> self._do_exit(exc_type)
/usr/lib/python3.8/site-packages/async_timeout/__init__.py:129:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , exc_type =
def _do_exit(self, exc_type: Optional[Type[BaseException]]) -> None:
if exc_type is asyncio.CancelledError and self._state == _State.TIMEOUT:
self._timeout_handler = None
> raise asyncio.TimeoutError
E asyncio.exceptions.TimeoutError
/usr/lib/python3.8/site-packages/async_timeout/__init__.py:212: TimeoutError
The above exception was the direct cause of the following exception:
self =
request =
async def send(self, request):
try:
proxy_url = self._proxy_config.proxy_url_for(request.url)
proxy_headers = self._proxy_config.proxy_headers_for(request.url)
url = request.url
headers = request.headers
data = request.body
if ensure_boolean(
os.environ.get('BOTO_EXPERIMENTAL__ADD_PROXY_HOST_HEADER', '')
):
# This is currently an "experimental" feature which provides
# no guarantees of backwards compatibility. It may be subject
# to change or removal in any patch version. Anyone opting in
# to this feature should strictly pin botocore.
host = urlparse(request.url).hostname
proxy_headers['host'] = host
# https://github.com/boto/botocore/issues/1255
headers['Accept-Encoding'] = 'identity'
headers_ = MultiDict(
(z[0], _text(z[1], encoding='utf-8')) for z in headers.items()
)
if isinstance(data, io.IOBase):
data = _IOBaseWrapper(data)
url = URL(url, encoded=True)
> response = await self._session.request(
request.method,
url=url,
headers=headers_,
data=data,
proxy=proxy_url,
proxy_headers=proxy_headers,
)
aiobotocore/httpsession.py:202:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , method = 'PUT', str_or_url = URL('http://169.254.169.254/latest/api/token')
async def _request(
self,
method: str,
str_or_url: StrOrURL,
*,
params: Optional[Mapping[str, str]] = None,
data: Any = None,
json: Any = None,
cookies: Optional[LooseCookies] = None,
headers: Optional[LooseHeaders] = None,
skip_auto_headers: Optional[Iterable[str]] = None,
auth: Optional[BasicAuth] = None,
allow_redirects: bool = True,
max_redirects: int = 10,
compress: Optional[str] = None,
chunked: Optional[bool] = None,
expect100: bool = False,
raise_for_status: Optional[bool] = None,
read_until_eof: bool = True,
proxy: Optional[StrOrURL] = None,
proxy_auth: Optional[BasicAuth] = None,
timeout: Union[ClientTimeout, object] = sentinel,
verify_ssl: Optional[bool] = None,
fingerprint: Optional[bytes] = None,
ssl_context: Optional[SSLContext] = None,
ssl: Optional[Union[SSLContext, bool, Fingerprint]] = None,
proxy_headers: Optional[LooseHeaders] = None,
trace_request_ctx: Optional[SimpleNamespace] = None,
read_bufsize: Optional[int] = None,
) -> ClientResponse:
# NOTE: timeout clamps existing connect and read timeouts. We cannot
# set the default to None because we need to detect if the user wants
# to use the existing timeouts by setting timeout to None.
if self.closed:
raise RuntimeError("Session is closed")
ssl = _merge_ssl_params(ssl, verify_ssl, ssl_context, fingerprint)
if data is not None and json is not None:
raise ValueError(
"data and json parameters can not be used at the same time"
)
elif json is not None:
data = payload.JsonPayload(json, dumps=self._json_serialize)
if not isinstance(chunked, bool) and chunked is not None:
warnings.warn("Chunk size is deprecated #1615", DeprecationWarning)
redirects = 0
history = []
version = self._version
# Merge with default headers and transform to CIMultiDict
headers = self._prepare_headers(headers)
proxy_headers = self._prepare_headers(proxy_headers)
try:
url = self._build_url(str_or_url)
except ValueError as e:
raise InvalidURL(str_or_url) from e
skip_headers = set(self._skip_auto_headers)
if skip_auto_headers is not None:
for i in skip_auto_headers:
skip_headers.add(istr(i))
if proxy is not None:
try:
proxy = URL(proxy)
except ValueError as e:
raise InvalidURL(proxy) from e
if timeout is sentinel:
real_timeout = self._timeout # type: ClientTimeout
else:
if not isinstance(timeout, ClientTimeout):
real_timeout = ClientTimeout(total=timeout) # type: ignore[arg-type]
else:
real_timeout = timeout
# timeout is cumulative for all request operations
# (request, redirects, responses, data consuming)
tm = TimeoutHandle(self._loop, real_timeout.total)
handle = tm.start()
if read_bufsize is None:
read_bufsize = self._read_bufsize
traces = [
Trace(
self,
trace_config,
trace_config.trace_config_ctx(trace_request_ctx=trace_request_ctx),
)
for trace_config in self._trace_configs
]
for trace in traces:
await trace.send_request_start(method, url.update_query(params), headers)
timer = tm.timer()
try:
with timer:
while True:
url, auth_from_url = strip_auth_from_url(url)
if auth and auth_from_url:
raise ValueError(
"Cannot combine AUTH argument with "
"credentials encoded in URL"
)
if auth is None:
auth = auth_from_url
if auth is None:
auth = self._default_auth
# It would be confusing if we support explicit
# Authorization header with auth argument
if (
headers is not None
and auth is not None
and hdrs.AUTHORIZATION in headers
):
raise ValueError(
"Cannot combine AUTHORIZATION header "
"with AUTH argument or credentials "
"encoded in URL"
)
all_cookies = self._cookie_jar.filter_cookies(url)
if cookies is not None:
tmp_cookie_jar = CookieJar()
tmp_cookie_jar.update_cookies(cookies)
req_cookies = tmp_cookie_jar.filter_cookies(url)
if req_cookies:
all_cookies.load(req_cookies)
if proxy is not None:
proxy = URL(proxy)
elif self._trust_env:
with suppress(LookupError):
proxy, proxy_auth = get_env_proxy_for_url(url)
req = self._request_class(
method,
url,
params=params,
headers=headers,
skip_auto_headers=skip_headers,
data=data,
cookies=all_cookies,
auth=auth,
version=version,
compress=compress,
chunked=chunked,
expect100=expect100,
loop=self._loop,
response_class=self._response_class,
proxy=proxy,
proxy_auth=proxy_auth,
timer=timer,
session=self,
ssl=ssl,
proxy_headers=proxy_headers,
traces=traces,
)
# connection timeout
try:
async with ceil_timeout(real_timeout.connect):
assert self._connector is not None
conn = await self._connector.connect(
req, traces=traces, timeout=real_timeout
)
except asyncio.TimeoutError as exc:
> raise ServerTimeoutError(
"Connection timeout " "to host {}".format(url)
) from exc
E aiohttp.client_exceptions.ServerTimeoutError: Connection timeout to host http://169.254.169.254/latest/api/token
/usr/lib64/python3.8/site-packages/aiohttp/client.py:539: ServerTimeoutError
During handling of the above exception, another exception occurred:
session =
@pytest.mark.asyncio
async def test_mturk_stubber(session):
> async with session.create_client(
'mturk', region_name='us-east-1'
) as client:
tests/test_mturk.py:26:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
aiobotocore/session.py:26: in __aenter__
self._client = await self._coro
aiobotocore/session.py:169: in _create_client
credentials = await self.get_credentials()
aiobotocore/session.py:79: in get_credentials
self._credentials = await (
aiobotocore/credentials.py:951: in load_credentials
creds = await provider.load()
aiobotocore/credentials.py:537: in load
metadata = await fetcher.retrieve_iam_role_credentials()
aiobotocore/utils.py:214: in retrieve_iam_role_credentials
token = await self._fetch_metadata_token()
aiobotocore/utils.py:116: in _fetch_metadata_token
response = await session.send(request.prepare())
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self =
request =
async def send(self, request):
try:
proxy_url = self._proxy_config.proxy_url_for(request.url)
proxy_headers = self._proxy_config.proxy_headers_for(request.url)
url = request.url
headers = request.headers
data = request.body
if ensure_boolean(
os.environ.get('BOTO_EXPERIMENTAL__ADD_PROXY_HOST_HEADER', '')
):
# This is currently an "experimental" feature which provides
# no guarantees of backwards compatibility. It may be subject
# to change or removal in any patch version. Anyone opting in
# to this feature should strictly pin botocore.
host = urlparse(request.url).hostname
proxy_headers['host'] = host
# https://github.com/boto/botocore/issues/1255
headers['Accept-Encoding'] = 'identity'
headers_ = MultiDict(
(z[0], _text(z[1], encoding='utf-8')) for z in headers.items()
)
if isinstance(data, io.IOBase):
data = _IOBaseWrapper(data)
url = URL(url, encoded=True)
response = await self._session.request(
request.method,
url=url,
headers=headers_,
data=data,
proxy=proxy_url,
proxy_headers=proxy_headers,
)
http_response = aiobotocore.awsrequest.AioAWSResponse(
str(response.url), response.status, response.headers, response
)
if not request.stream_output:
# Cause the raw stream to be exhausted immediately. We do it
# this way instead of using preload_content because
# preload_content will never buffer chunked responses
await http_response.content
return http_response
except ClientSSLError as e:
raise SSLError(endpoint_url=request.url, error=e)
except (ClientProxyConnectionError, ClientHttpProxyError) as e:
raise ProxyConnectionError(
proxy_url=mask_proxy_url(proxy_url), error=e
)
except (
ServerDisconnectedError,
aiohttp.ClientPayloadError,
aiohttp.http_exceptions.BadStatusLine,
) as e:
raise ConnectionClosedError(
error=e, request=request, endpoint_url=request.url
)
except ServerTimeoutError as e:
if str(e).lower().startswith('connect'):
> raise ConnectTimeoutError(endpoint_url=request.url, error=e)
E botocore.exceptions.ConnectTimeoutError: Connect timeout on endpoint URL: "http://169.254.169.254/latest/api/token"
aiobotocore/httpsession.py:238: ConnectTimeoutError
_______________________________________________________________________________ test_patches _______________________________________________________________________________
@pytest.mark.moto
def test_patches():
print(
"Botocore version: {} aiohttp version: {}".format(
botocore.__version__, aiohttp.__version__
)
)
success = True
for obj, digests in chain(_AIOHTTP_DIGESTS.items(), _API_DIGESTS.items()):
try:
source = getsource(obj)
except TypeError:
obj = obj.fget
source = getsource(obj)
digest = hashlib.sha1(source.encode('utf-8')).hexdigest()
if digest not in digests:
print(
"Digest of {}:{} not found in: {}".format(
obj.__qualname__, digest, digests
)
)
success = False
> assert success
E assert False
tests/test_patches.py:632: AssertionError
--------------------------------------------------------------------------- Captured stdout call ---------------------------------------------------------------------------
Botocore version: 1.27.57 aiohttp version: 3.8.1
Digest of ClientResponse:9da098725acbea71b221c556f72dae287f853a94 not found in: {'225e8033bfcff8cccbc2e975d7bd0c7993f14366', 'e178726065b609c69a1c02e8bb78f22efce90792'}
___________________________________________________________________ test_get_missing_endpoint_attributes ___________________________________________________________________
sns_client =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_get_missing_endpoint_attributes(sns_client):
with pytest.raises(botocore.exceptions.ClientError):
> await sns_client.get_endpoint_attributes(EndpointArn="arn1")
E AttributeError: 'async_generator' object has no attribute 'get_endpoint_attributes'
tests/test_sns.py:97: AttributeError
________________________________________________________________________ test_platform_applications ________________________________________________________________________
sns_client =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_platform_applications(sns_client):
> await sns_client.create_platform_application(
Name="app1",
Platform="APNS",
Attributes={},
)
E AttributeError: 'async_generator' object has no attribute 'create_platform_application'
tests/test_sns.py:103: AttributeError
_____________________________________________________________________________ test_list_queues _____________________________________________________________________________
sqs_client = , sqs_queue_url =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_list_queues(sqs_client, sqs_queue_url):
> response = await sqs_client.list_queues()
E AttributeError: 'async_generator' object has no attribute 'list_queues'
tests/test_sqs.py:9: AttributeError
___________________________________________________________________________ test_get_queue_name ____________________________________________________________________________
sqs_client = , sqs_queue_url =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_get_queue_name(sqs_client, sqs_queue_url):
> queue_name = sqs_queue_url.rsplit('/', 1)[-1]
E AttributeError: 'async_generator' object has no attribute 'rsplit'
tests/test_sqs.py:18: AttributeError
________________________________________________________________________ test_put_pull_delete_test _________________________________________________________________________
sqs_client = , sqs_queue_url =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_put_pull_delete_test(sqs_client, sqs_queue_url):
> response = await sqs_client.send_message(
QueueUrl=sqs_queue_url,
MessageBody='test_message_1',
MessageAttributes={
'attr1': {'DataType': 'String', 'StringValue': 'value1'}
},
)
E AttributeError: 'async_generator' object has no attribute 'send_message'
tests/test_sqs.py:29: AttributeError
____________________________________________________________________________ test_put_pull_wait ____________________________________________________________________________
sqs_client = , sqs_queue_url =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_put_pull_wait(sqs_client, sqs_queue_url):
start = time.perf_counter()
> response = await sqs_client.receive_message(
QueueUrl=sqs_queue_url, WaitTimeSeconds=2
)
E AttributeError: 'async_generator' object has no attribute 'receive_message'
tests/test_sqs.py:65: AttributeError
_________________________________________________________________________________ test_sqs _________________________________________________________________________________
cloudformation_client =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_sqs(cloudformation_client):
cloudformation_template = """{
"AWSTemplateFormatVersion": "2010-09-09",
"Resources": {
"queue1": {
"Type": "AWS::SQS::Queue",
"Properties": {
"QueueName": "my-queue"
}
}
}
}"""
# Create stack
> resp = await cloudformation_client.create_stack(
StackName='my-stack', TemplateBody=cloudformation_template
)
E AttributeError: 'async_generator' object has no attribute 'create_stack'
tests/test_waiter.py:20: AttributeError
___________________________________________________________________________ test_get_credentials ___________________________________________________________________________
self = , req =
timeout = ClientTimeout(total=None, connect=None, sock_read=1, sock_connect=1), client_error =
args = (functools.partial(, loop=<_UnixSelectorEventLoop running=False closed=False debug=False>), 'fd00:ec2::254', 80)
kwargs = {'family': 0, 'flags': 0, 'local_addr': None, 'proto': 0, ...}
async def _wrap_create_connection(
self,
*args: Any,
req: "ClientRequest",
timeout: "ClientTimeout",
client_error: Type[Exception] = ClientConnectorError,
**kwargs: Any,
) -> Tuple[asyncio.Transport, ResponseHandler]:
try:
async with ceil_timeout(timeout.sock_connect):
> return await self._loop.create_connection(*args, **kwargs) # type: ignore[return-value] # noqa
/usr/lib64/python3.8/site-packages/aiohttp/connector.py:986:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <_UnixSelectorEventLoop running=False closed=False debug=False>
protocol_factory = functools.partial(, loop=<_UnixSelectorEventLoop running=False closed=False debug=False>)
host = 'fd00:ec2::254', port = 80
async def create_connection(
self, protocol_factory, host=None, port=None,
*, ssl=None, family=0,
proto=0, flags=0, sock=None,
local_addr=None, server_hostname=None,
ssl_handshake_timeout=None,
happy_eyeballs_delay=None, interleave=None):
"""Connect to a TCP server.
Create a streaming transport connection to a given Internet host and
port: socket family AF_INET or socket.AF_INET6 depending on host (or
family if specified), socket type SOCK_STREAM. protocol_factory must be
a callable returning a protocol instance.
This method is a coroutine which will try to establish the connection
in the background. When successful, the coroutine returns a
(transport, protocol) pair.
"""
if server_hostname is not None and not ssl:
raise ValueError('server_hostname is only meaningful with ssl')
if server_hostname is None and ssl:
# Use host as default for server_hostname. It is an error
# if host is empty or not set, e.g. when an
# already-connected socket was passed or when only a port
# is given. To avoid this error, you can pass
# server_hostname='' -- this will bypass the hostname
# check. (This also means that if host is a numeric
# IP/IPv6 address, we will attempt to verify that exact
# address; this will probably fail, but it is possible to
# create a certificate for a specific IP address, so we
# don't judge it here.)
if not host:
raise ValueError('You must set server_hostname '
'when using ssl without a host')
server_hostname = host
if ssl_handshake_timeout is not None and not ssl:
raise ValueError(
'ssl_handshake_timeout is only meaningful with ssl')
if happy_eyeballs_delay is not None and interleave is None:
# If using happy eyeballs, default to interleave addresses by family
interleave = 1
if host is not None or port is not None:
if sock is not None:
raise ValueError(
'host/port and sock can not be specified at the same time')
infos = await self._ensure_resolved(
(host, port), family=family,
type=socket.SOCK_STREAM, proto=proto, flags=flags, loop=self)
if not infos:
raise OSError('getaddrinfo() returned empty list')
if local_addr is not None:
laddr_infos = await self._ensure_resolved(
local_addr, family=family,
type=socket.SOCK_STREAM, proto=proto,
flags=flags, loop=self)
if not laddr_infos:
raise OSError('getaddrinfo() returned empty list')
else:
laddr_infos = None
if interleave:
infos = _interleave_addrinfos(infos, interleave)
exceptions = []
if happy_eyeballs_delay is None:
# not using happy eyeballs
for addrinfo in infos:
try:
sock = await self._connect_sock(
exceptions, addrinfo, laddr_infos)
break
except OSError:
continue
else: # using happy eyeballs
sock, _, _ = await staggered.staggered_race(
(functools.partial(self._connect_sock,
exceptions, addrinfo, laddr_infos)
for addrinfo in infos),
happy_eyeballs_delay, loop=self)
if sock is None:
exceptions = [exc for sub in exceptions for exc in sub]
if len(exceptions) == 1:
> raise exceptions[0]
/usr/lib64/python3.8/asyncio/base_events.py:1025:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <_UnixSelectorEventLoop running=False closed=False debug=False>
protocol_factory = functools.partial(, loop=<_UnixSelectorEventLoop running=False closed=False debug=False>)
host = 'fd00:ec2::254', port = 80
async def create_connection(
self, protocol_factory, host=None, port=None,
*, ssl=None, family=0,
proto=0, flags=0, sock=None,
local_addr=None, server_hostname=None,
ssl_handshake_timeout=None,
happy_eyeballs_delay=None, interleave=None):
"""Connect to a TCP server.
Create a streaming transport connection to a given Internet host and
port: socket family AF_INET or socket.AF_INET6 depending on host (or
family if specified), socket type SOCK_STREAM. protocol_factory must be
a callable returning a protocol instance.
This method is a coroutine which will try to establish the connection
in the background. When successful, the coroutine returns a
(transport, protocol) pair.
"""
if server_hostname is not None and not ssl:
raise ValueError('server_hostname is only meaningful with ssl')
if server_hostname is None and ssl:
# Use host as default for server_hostname. It is an error
# if host is empty or not set, e.g. when an
# already-connected socket was passed or when only a port
# is given. To avoid this error, you can pass
# server_hostname='' -- this will bypass the hostname
# check. (This also means that if host is a numeric
# IP/IPv6 address, we will attempt to verify that exact
# address; this will probably fail, but it is possible to
# create a certificate for a specific IP address, so we
# don't judge it here.)
if not host:
raise ValueError('You must set server_hostname '
'when using ssl without a host')
server_hostname = host
if ssl_handshake_timeout is not None and not ssl:
raise ValueError(
'ssl_handshake_timeout is only meaningful with ssl')
if happy_eyeballs_delay is not None and interleave is None:
# If using happy eyeballs, default to interleave addresses by family
interleave = 1
if host is not None or port is not None:
if sock is not None:
raise ValueError(
'host/port and sock can not be specified at the same time')
infos = await self._ensure_resolved(
(host, port), family=family,
type=socket.SOCK_STREAM, proto=proto, flags=flags, loop=self)
if not infos:
raise OSError('getaddrinfo() returned empty list')
if local_addr is not None:
laddr_infos = await self._ensure_resolved(
local_addr, family=family,
type=socket.SOCK_STREAM, proto=proto,
flags=flags, loop=self)
if not laddr_infos:
raise OSError('getaddrinfo() returned empty list')
else:
laddr_infos = None
if interleave:
infos = _interleave_addrinfos(infos, interleave)
exceptions = []
if happy_eyeballs_delay is None:
# not using happy eyeballs
for addrinfo in infos:
try:
> sock = await self._connect_sock(
exceptions, addrinfo, laddr_infos)
/usr/lib64/python3.8/asyncio/base_events.py:1010:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <_UnixSelectorEventLoop running=False closed=False debug=False>, exceptions = [[OSError(101, 'Network is unreachable')]]
addr_info = (, , 6, '', ('fd00:ec2::254', 80, 0, 0)), local_addr_infos = None
async def _connect_sock(self, exceptions, addr_info, local_addr_infos=None):
"""Create, bind and connect one socket."""
my_exceptions = []
exceptions.append(my_exceptions)
family, type_, proto, _, address = addr_info
sock = None
try:
sock = socket.socket(family=family, type=type_, proto=proto)
sock.setblocking(False)
if local_addr_infos is not None:
for _, _, _, _, laddr in local_addr_infos:
try:
sock.bind(laddr)
break
except OSError as exc:
msg = (
f'error while attempting to bind on '
f'address {laddr!r}: '
f'{exc.strerror.lower()}'
)
exc = OSError(exc.errno, msg)
my_exceptions.append(exc)
else: # all bind attempts failed
raise my_exceptions.pop()
> await self.sock_connect(sock, address)
/usr/lib64/python3.8/asyncio/base_events.py:924:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <_UnixSelectorEventLoop running=False closed=False debug=False>
sock = , address = ('fd00:ec2::254', 80, 0, 0)
async def sock_connect(self, sock, address):
"""Connect to a remote socket at address.
This method is a coroutine.
"""
_check_ssl_socket(sock)
if self._debug and sock.gettimeout() != 0:
raise ValueError("the socket must be non-blocking")
if not hasattr(socket, 'AF_UNIX') or sock.family != socket.AF_UNIX:
resolved = await self._ensure_resolved(
address, family=sock.family, proto=sock.proto, loop=self)
_, _, _, _, address = resolved[0]
fut = self.create_future()
self._sock_connect(fut, sock, address)
> return await fut
/usr/lib64/python3.8/asyncio/selector_events.py:496:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <_UnixSelectorEventLoop running=False closed=False debug=False>, fut =
sock = , address = ('fd00:ec2::254', 80, 0, 0)
def _sock_connect(self, fut, sock, address):
fd = sock.fileno()
try:
> sock.connect(address)
E OSError: [Errno 101] Network is unreachable
/usr/lib64/python3.8/asyncio/selector_events.py:501: OSError
The above exception was the direct cause of the following exception:
self =
request = , 'Content-Length': '0', 'Accept-Encoding': 'identity'}>
async def send(self, request):
try:
proxy_url = self._proxy_config.proxy_url_for(request.url)
proxy_headers = self._proxy_config.proxy_headers_for(request.url)
url = request.url
headers = request.headers
data = request.body
if ensure_boolean(
os.environ.get('BOTO_EXPERIMENTAL__ADD_PROXY_HOST_HEADER', '')
):
# This is currently an "experimental" feature which provides
# no guarantees of backwards compatibility. It may be subject
# to change or removal in any patch version. Anyone opting in
# to this feature should strictly pin botocore.
host = urlparse(request.url).hostname
proxy_headers['host'] = host
# https://github.com/boto/botocore/issues/1255
headers['Accept-Encoding'] = 'identity'
headers_ = MultiDict(
(z[0], _text(z[1], encoding='utf-8')) for z in headers.items()
)
if isinstance(data, io.IOBase):
data = _IOBaseWrapper(data)
url = URL(url, encoded=True)
> response = await self._session.request(
request.method,
url=url,
headers=headers_,
data=data,
proxy=proxy_url,
proxy_headers=proxy_headers,
)
aiobotocore/httpsession.py:202:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , method = 'PUT', str_or_url = URL('http://[fd00:ec2::254]/latest/api/token')
async def _request(
self,
method: str,
str_or_url: StrOrURL,
*,
params: Optional[Mapping[str, str]] = None,
data: Any = None,
json: Any = None,
cookies: Optional[LooseCookies] = None,
headers: Optional[LooseHeaders] = None,
skip_auto_headers: Optional[Iterable[str]] = None,
auth: Optional[BasicAuth] = None,
allow_redirects: bool = True,
max_redirects: int = 10,
compress: Optional[str] = None,
chunked: Optional[bool] = None,
expect100: bool = False,
raise_for_status: Optional[bool] = None,
read_until_eof: bool = True,
proxy: Optional[StrOrURL] = None,
proxy_auth: Optional[BasicAuth] = None,
timeout: Union[ClientTimeout, object] = sentinel,
verify_ssl: Optional[bool] = None,
fingerprint: Optional[bytes] = None,
ssl_context: Optional[SSLContext] = None,
ssl: Optional[Union[SSLContext, bool, Fingerprint]] = None,
proxy_headers: Optional[LooseHeaders] = None,
trace_request_ctx: Optional[SimpleNamespace] = None,
read_bufsize: Optional[int] = None,
) -> ClientResponse:
# NOTE: timeout clamps existing connect and read timeouts. We cannot
# set the default to None because we need to detect if the user wants
# to use the existing timeouts by setting timeout to None.
if self.closed:
raise RuntimeError("Session is closed")
ssl = _merge_ssl_params(ssl, verify_ssl, ssl_context, fingerprint)
if data is not None and json is not None:
raise ValueError(
"data and json parameters can not be used at the same time"
)
elif json is not None:
data = payload.JsonPayload(json, dumps=self._json_serialize)
if not isinstance(chunked, bool) and chunked is not None:
warnings.warn("Chunk size is deprecated #1615", DeprecationWarning)
redirects = 0
history = []
version = self._version
# Merge with default headers and transform to CIMultiDict
headers = self._prepare_headers(headers)
proxy_headers = self._prepare_headers(proxy_headers)
try:
url = self._build_url(str_or_url)
except ValueError as e:
raise InvalidURL(str_or_url) from e
skip_headers = set(self._skip_auto_headers)
if skip_auto_headers is not None:
for i in skip_auto_headers:
skip_headers.add(istr(i))
if proxy is not None:
try:
proxy = URL(proxy)
except ValueError as e:
raise InvalidURL(proxy) from e
if timeout is sentinel:
real_timeout = self._timeout # type: ClientTimeout
else:
if not isinstance(timeout, ClientTimeout):
real_timeout = ClientTimeout(total=timeout) # type: ignore[arg-type]
else:
real_timeout = timeout
# timeout is cumulative for all request operations
# (request, redirects, responses, data consuming)
tm = TimeoutHandle(self._loop, real_timeout.total)
handle = tm.start()
if read_bufsize is None:
read_bufsize = self._read_bufsize
traces = [
Trace(
self,
trace_config,
trace_config.trace_config_ctx(trace_request_ctx=trace_request_ctx),
)
for trace_config in self._trace_configs
]
for trace in traces:
await trace.send_request_start(method, url.update_query(params), headers)
timer = tm.timer()
try:
with timer:
while True:
url, auth_from_url = strip_auth_from_url(url)
if auth and auth_from_url:
raise ValueError(
"Cannot combine AUTH argument with "
"credentials encoded in URL"
)
if auth is None:
auth = auth_from_url
if auth is None:
auth = self._default_auth
# It would be confusing if we support explicit
# Authorization header with auth argument
if (
headers is not None
and auth is not None
and hdrs.AUTHORIZATION in headers
):
raise ValueError(
"Cannot combine AUTHORIZATION header "
"with AUTH argument or credentials "
"encoded in URL"
)
all_cookies = self._cookie_jar.filter_cookies(url)
if cookies is not None:
tmp_cookie_jar = CookieJar()
tmp_cookie_jar.update_cookies(cookies)
req_cookies = tmp_cookie_jar.filter_cookies(url)
if req_cookies:
all_cookies.load(req_cookies)
if proxy is not None:
proxy = URL(proxy)
elif self._trust_env:
with suppress(LookupError):
proxy, proxy_auth = get_env_proxy_for_url(url)
req = self._request_class(
method,
url,
params=params,
headers=headers,
skip_auto_headers=skip_headers,
data=data,
cookies=all_cookies,
auth=auth,
version=version,
compress=compress,
chunked=chunked,
expect100=expect100,
loop=self._loop,
response_class=self._response_class,
proxy=proxy,
proxy_auth=proxy_auth,
timer=timer,
session=self,
ssl=ssl,
proxy_headers=proxy_headers,
traces=traces,
)
# connection timeout
try:
async with ceil_timeout(real_timeout.connect):
assert self._connector is not None
> conn = await self._connector.connect(
req, traces=traces, timeout=real_timeout
)
/usr/lib64/python3.8/site-packages/aiohttp/client.py:535:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , req = , traces = []
timeout = ClientTimeout(total=None, connect=None, sock_read=1, sock_connect=1)
async def connect(
self, req: "ClientRequest", traces: List["Trace"], timeout: "ClientTimeout"
) -> Connection:
"""Get from pool or create new connection."""
key = req.connection_key
available = self._available_connections(key)
# Wait if there are no available connections or if there are/were
# waiters (i.e. don't steal connection from a waiter about to wake up)
if available <= 0 or key in self._waiters:
fut = self._loop.create_future()
# This connection will now count towards the limit.
self._waiters[key].append(fut)
if traces:
for trace in traces:
await trace.send_connection_queued_start()
try:
await fut
except BaseException as e:
if key in self._waiters:
# remove a waiter even if it was cancelled, normally it's
# removed when it's notified
try:
self._waiters[key].remove(fut)
except ValueError: # fut may no longer be in list
pass
raise e
finally:
if key in self._waiters and not self._waiters[key]:
del self._waiters[key]
if traces:
for trace in traces:
await trace.send_connection_queued_end()
proto = self._get(key)
if proto is None:
placeholder = cast(ResponseHandler, _TransportPlaceholder())
self._acquired.add(placeholder)
self._acquired_per_host[key].add(placeholder)
if traces:
for trace in traces:
await trace.send_connection_create_start()
try:
> proto = await self._create_connection(req, traces, timeout)
/usr/lib64/python3.8/site-packages/aiohttp/connector.py:542:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , req = , traces = []
timeout = ClientTimeout(total=None, connect=None, sock_read=1, sock_connect=1)
async def _create_connection(
self, req: "ClientRequest", traces: List["Trace"], timeout: "ClientTimeout"
) -> ResponseHandler:
"""Create connection.
Has same keyword arguments as BaseEventLoop.create_connection.
"""
if req.proxy:
_, proto = await self._create_proxy_connection(req, traces, timeout)
else:
> _, proto = await self._create_direct_connection(req, traces, timeout)
/usr/lib64/python3.8/site-packages/aiohttp/connector.py:907:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , req = , traces = []
timeout = ClientTimeout(total=None, connect=None, sock_read=1, sock_connect=1)
async def _create_direct_connection(
self,
req: "ClientRequest",
traces: List["Trace"],
timeout: "ClientTimeout",
*,
client_error: Type[Exception] = ClientConnectorError,
) -> Tuple[asyncio.Transport, ResponseHandler]:
sslcontext = self._get_ssl_context(req)
fingerprint = self._get_fingerprint(req)
host = req.url.raw_host
assert host is not None
port = req.port
assert port is not None
host_resolved = asyncio.ensure_future(
self._resolve_host(host, port, traces=traces), loop=self._loop
)
try:
# Cancelling this lookup should not cancel the underlying lookup
# or else the cancel event will get broadcast to all the waiters
# across all connections.
hosts = await asyncio.shield(host_resolved)
except asyncio.CancelledError:
def drop_exception(fut: "asyncio.Future[List[Dict[str, Any]]]") -> None:
with suppress(Exception, asyncio.CancelledError):
fut.result()
host_resolved.add_done_callback(drop_exception)
raise
except OSError as exc:
# in case of proxy it is not ClientProxyConnectionError
# it is problem of resolving proxy ip itself
raise ClientConnectorError(req.connection_key, exc) from exc
last_exc = None # type: Optional[Exception]
for hinfo in hosts:
host = hinfo["host"]
port = hinfo["port"]
try:
transp, proto = await self._wrap_create_connection(
self._factory,
host,
port,
timeout=timeout,
ssl=sslcontext,
family=hinfo["family"],
proto=hinfo["proto"],
flags=hinfo["flags"],
server_hostname=hinfo["hostname"] if sslcontext else None,
local_addr=self._local_addr,
req=req,
client_error=client_error,
)
except ClientConnectorError as exc:
last_exc = exc
continue
if req.is_ssl() and fingerprint:
try:
fingerprint.check(transp)
except ServerFingerprintMismatch as exc:
transp.close()
if not self._cleanup_closed_disabled:
self._cleanup_closed_transports.append(transp)
last_exc = exc
continue
return transp, proto
else:
assert last_exc is not None
> raise last_exc
/usr/lib64/python3.8/site-packages/aiohttp/connector.py:1206:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , req = , traces = []
timeout = ClientTimeout(total=None, connect=None, sock_read=1, sock_connect=1)
async def _create_direct_connection(
self,
req: "ClientRequest",
traces: List["Trace"],
timeout: "ClientTimeout",
*,
client_error: Type[Exception] = ClientConnectorError,
) -> Tuple[asyncio.Transport, ResponseHandler]:
sslcontext = self._get_ssl_context(req)
fingerprint = self._get_fingerprint(req)
host = req.url.raw_host
assert host is not None
port = req.port
assert port is not None
host_resolved = asyncio.ensure_future(
self._resolve_host(host, port, traces=traces), loop=self._loop
)
try:
# Cancelling this lookup should not cancel the underlying lookup
# or else the cancel event will get broadcast to all the waiters
# across all connections.
hosts = await asyncio.shield(host_resolved)
except asyncio.CancelledError:
def drop_exception(fut: "asyncio.Future[List[Dict[str, Any]]]") -> None:
with suppress(Exception, asyncio.CancelledError):
fut.result()
host_resolved.add_done_callback(drop_exception)
raise
except OSError as exc:
# in case of proxy it is not ClientProxyConnectionError
# it is problem of resolving proxy ip itself
raise ClientConnectorError(req.connection_key, exc) from exc
last_exc = None # type: Optional[Exception]
for hinfo in hosts:
host = hinfo["host"]
port = hinfo["port"]
try:
> transp, proto = await self._wrap_create_connection(
self._factory,
host,
port,
timeout=timeout,
ssl=sslcontext,
family=hinfo["family"],
proto=hinfo["proto"],
flags=hinfo["flags"],
server_hostname=hinfo["hostname"] if sslcontext else None,
local_addr=self._local_addr,
req=req,
client_error=client_error,
)
/usr/lib64/python3.8/site-packages/aiohttp/connector.py:1175:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , req =
timeout = ClientTimeout(total=None, connect=None, sock_read=1, sock_connect=1), client_error =
args = (functools.partial(, loop=<_UnixSelectorEventLoop running=False closed=False debug=False>), 'fd00:ec2::254', 80)
kwargs = {'family': 0, 'flags': 0, 'local_addr': None, 'proto': 0, ...}
async def _wrap_create_connection(
self,
*args: Any,
req: "ClientRequest",
timeout: "ClientTimeout",
client_error: Type[Exception] = ClientConnectorError,
**kwargs: Any,
) -> Tuple[asyncio.Transport, ResponseHandler]:
try:
async with ceil_timeout(timeout.sock_connect):
return await self._loop.create_connection(*args, **kwargs) # type: ignore[return-value] # noqa
except cert_errors as exc:
raise ClientConnectorCertificateError(req.connection_key, exc) from exc
except ssl_errors as exc:
raise ClientConnectorSSLError(req.connection_key, exc) from exc
except OSError as exc:
> raise client_error(req.connection_key, exc) from exc
E aiohttp.client_exceptions.ClientConnectorError: Cannot connect to host fd00:ec2::254:80 ssl:default [Network is unreachable]
/usr/lib64/python3.8/site-packages/aiohttp/connector.py:992: ClientConnectorError
During handling of the above exception, another exception occurred:
mock_session = ._f at 0x7f3e252f1d30>
@pytest.mark.asyncio
async def test_get_credentials(mock_session):
session = mock_session()
> creds = await credentials.get_credentials(session)
tests/boto_tests/test_credentials.py:876:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
aiobotocore/credentials.py:199: in get_credentials
return await resolver.load_credentials()
aiobotocore/credentials.py:951: in load_credentials
creds = await provider.load()
aiobotocore/credentials.py:537: in load
metadata = await fetcher.retrieve_iam_role_credentials()
aiobotocore/utils.py:214: in retrieve_iam_role_credentials
token = await self._fetch_metadata_token()
aiobotocore/utils.py:116: in _fetch_metadata_token
response = await session.send(request.prepare())
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self =
request = , 'Content-Length': '0', 'Accept-Encoding': 'identity'}>
async def send(self, request):
try:
proxy_url = self._proxy_config.proxy_url_for(request.url)
proxy_headers = self._proxy_config.proxy_headers_for(request.url)
url = request.url
headers = request.headers
data = request.body
if ensure_boolean(
os.environ.get('BOTO_EXPERIMENTAL__ADD_PROXY_HOST_HEADER', '')
):
# This is currently an "experimental" feature which provides
# no guarantees of backwards compatibility. It may be subject
# to change or removal in any patch version. Anyone opting in
# to this feature should strictly pin botocore.
host = urlparse(request.url).hostname
proxy_headers['host'] = host
# https://github.com/boto/botocore/issues/1255
headers['Accept-Encoding'] = 'identity'
headers_ = MultiDict(
(z[0], _text(z[1], encoding='utf-8')) for z in headers.items()
)
if isinstance(data, io.IOBase):
data = _IOBaseWrapper(data)
url = URL(url, encoded=True)
response = await self._session.request(
request.method,
url=url,
headers=headers_,
data=data,
proxy=proxy_url,
proxy_headers=proxy_headers,
)
http_response = aiobotocore.awsrequest.AioAWSResponse(
str(response.url), response.status, response.headers, response
)
if not request.stream_output:
# Cause the raw stream to be exhausted immediately. We do it
# this way instead of using preload_content because
# preload_content will never buffer chunked responses
await http_response.content
return http_response
except ClientSSLError as e:
raise SSLError(endpoint_url=request.url, error=e)
except (ClientProxyConnectionError, ClientHttpProxyError) as e:
raise ProxyConnectionError(
proxy_url=mask_proxy_url(proxy_url), error=e
)
except (
ServerDisconnectedError,
aiohttp.ClientPayloadError,
aiohttp.http_exceptions.BadStatusLine,
) as e:
raise ConnectionClosedError(
error=e, request=request, endpoint_url=request.url
)
except ServerTimeoutError as e:
if str(e).lower().startswith('connect'):
raise ConnectTimeoutError(endpoint_url=request.url, error=e)
else:
raise ReadTimeoutError(endpoint_url=request.url, error=e)
except (
ClientConnectorError,
ClientConnectionError,
socket.gaierror,
) as e:
> raise EndpointConnectionError(endpoint_url=request.url, error=e)
E botocore.exceptions.EndpointConnectionError: Could not connect to the endpoint URL: "http://[fd00:ec2::254]/latest/api/token"
aiobotocore/httpsession.py:246: EndpointConnectionError
____________________________________________________________ test_sso_credential_fetcher_can_fetch_credentials _____________________________________________________________
ssl_credential_fetcher_setup =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_sso_credential_fetcher_can_fetch_credentials(
ssl_credential_fetcher_setup,
):
self = ssl_credential_fetcher_setup
expected_params = {
> 'roleName': self.role_name,
'accountId': self.account_id,
'accessToken': self.access_token,
}
E AttributeError: 'async_generator' object has no attribute 'role_name'
tests/boto_tests/test_credentials.py:1115: AttributeError
__________________________________________________ test_sso_cred_fetcher_raises_helpful_message_on_unauthorized_exception __________________________________________________
ssl_credential_fetcher_setup =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_sso_cred_fetcher_raises_helpful_message_on_unauthorized_exception(
ssl_credential_fetcher_setup,
):
self = ssl_credential_fetcher_setup
expected_params = {
> 'roleName': self.role_name,
'accountId': self.account_id,
'accessToken': self.access_token,
}
E AttributeError: 'async_generator' object has no attribute 'role_name'
tests/boto_tests/test_credentials.py:1158: AttributeError
___________________________________________________________________ test_load_sso_credentials_with_cache ___________________________________________________________________
sso_provider_setup =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_load_sso_credentials_with_cache(sso_provider_setup):
self = sso_provider_setup
cached_creds = {
'Credentials': {
'AccessKeyId': 'cached-akid',
'SecretAccessKey': 'cached-sak',
'SessionToken': 'cached-st',
> 'Expiration': self.expires_at.strftime('%Y-%m-%dT%H:%M:%S%Z'),
}
}
E AttributeError: 'async_generator' object has no attribute 'expires_at'
tests/boto_tests/test_credentials.py:1275: AttributeError
_______________________________________________________________ test_load_sso_credentials_with_cache_expired _______________________________________________________________
sso_provider_setup =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_load_sso_credentials_with_cache_expired(sso_provider_setup):
self = sso_provider_setup
cached_creds = {
'Credentials': {
'AccessKeyId': 'expired-akid',
'SecretAccessKey': 'expired-sak',
'SessionToken': 'expired-st',
'Expiration': '2002-10-22T20:52:11UTC',
}
}
> self.cache[self.cached_creds_key] = cached_creds
E AttributeError: 'async_generator' object has no attribute 'cache'
tests/boto_tests/test_credentials.py:1298: AttributeError
_______________________________________________________________________ test_required_config_not_set _______________________________________________________________________
sso_provider_setup =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_required_config_not_set(sso_provider_setup):
self = sso_provider_setup
> del self.config['sso_start_url']
E AttributeError: 'async_generator' object has no attribute 'config'
tests/boto_tests/test_credentials.py:1314: AttributeError
___________________________________________________________________ test_signers_generate_db_auth_token ____________________________________________________________________
rds_client =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_signers_generate_db_auth_token(rds_client):
hostname = 'prod-instance.us-east-1.rds.amazonaws.com'
port = 3306
username = 'someusername'
clock = datetime.datetime(2016, 11, 7, 17, 39, 33, tzinfo=timezone.utc)
with mock.patch('datetime.datetime') as dt:
dt.utcnow.return_value = clock
> result = await aiobotocore.signers.generate_db_auth_token(
rds_client, hostname, port, username
)
tests/boto_tests/test_signers.py:22:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = , DBHostname = 'prod-instance.us-east-1.rds.amazonaws.com', Port = 3306, DBUsername = 'someusername'
Region = None
async def generate_db_auth_token(
self, DBHostname, Port, DBUsername, Region=None
):
"""Generates an auth token used to connect to a db with IAM credentials.
:type DBHostname: str
:param DBHostname: The hostname of the database to connect to.
:type Port: int
:param Port: The port number the database is listening on.
:type DBUsername: str
:param DBUsername: The username to log in as.
:type Region: str
:param Region: The region the database is in. If None, the client
region will be used.
:return: A presigned url which can be used as an auth token.
"""
region = Region
if region is None:
> region = self.meta.region_name
E AttributeError: 'async_generator' object has no attribute 'meta'
aiobotocore/signers.py:196: AttributeError
_____________________________________________________________________ test_kinesis_stream_json_parser ______________________________________________________________________
exit_stack =
@pytest.mark.asyncio
async def test_kinesis_stream_json_parser(exit_stack: AsyncExitStack):
# unfortunately moto doesn't support kinesis register_stream_consumer +
# subscribe_to_shard yet
stream_name = "my_stream"
stream_arn = consumer_arn = None
consumer_name = 'consumer'
session = aiobotocore.session.AioSession()
> kinesis_client = await exit_stack.enter_async_context(
session.create_client('kinesis')
)
E AttributeError: 'async_generator' object has no attribute 'enter_async_context'
tests/python3.8/test_eventstreams.py:19: AttributeError
_________________________________________________________________________ test_testsigner_get_auth _________________________________________________________________________
base_signer_setup =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_testsigner_get_auth(base_signer_setup: dict):
auth_cls = mock.Mock()
with mock.patch.dict(botocore.auth.AUTH_TYPE_MAPS, {'v4': auth_cls}):
> signer = base_signer_setup['signer']
E TypeError: 'coroutine' object is not subscriptable
tests/python3.8/boto_tests/test_signers.py:154: TypeError
_________________________________________________________________ test_testsigner_region_required_for_sig4 _________________________________________________________________
base_signer_setup =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_testsigner_region_required_for_sig4(base_signer_setup: dict):
signer = aiobotocore.signers.AioRequestSigner(
ServiceId('service_name'),
None,
'signing_name',
'v4',
> base_signer_setup['credentials'],
base_signer_setup['emitter'],
)
E TypeError: 'coroutine' object is not subscriptable
tests/python3.8/boto_tests/test_signers.py:173: TypeError
___________________________________________________________________ test_testsigner_custom_sign_version ____________________________________________________________________
base_signer_setup =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_testsigner_custom_sign_version(base_signer_setup: dict):
> signer = base_signer_setup['signer']
E TypeError: 'coroutine' object is not subscriptable
tests/python3.8/boto_tests/test_signers.py:184: TypeError
__________________________________________________________________ test_testsigner_choose_signer_override __________________________________________________________________
base_signer_setup =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_testsigner_choose_signer_override(base_signer_setup: dict):
auth_cls = mock.Mock()
auth_cls.REQUIRES_REGION = False
> base_signer_setup['emitter'].emit_until_response.return_value = (
None,
'custom',
)
E TypeError: 'coroutine' object is not subscriptable
tests/python3.8/boto_tests/test_signers.py:196: TypeError
__________________________________________________________________ test_testsigner_generate_presigned_url __________________________________________________________________
base_signer_setup =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_testsigner_generate_presigned_url(base_signer_setup: dict):
auth_cls = mock.Mock()
auth_cls.REQUIRES_REGION = True
request_dict = {
'headers': {},
'url': 'https://foo.com',
'body': b'',
'url_path': '/',
'method': 'GET',
'context': {},
}
with mock.patch.dict(botocore.auth.AUTH_TYPE_MAPS, {'v4-query': auth_cls}):
> signer = base_signer_setup['signer']
E TypeError: 'coroutine' object is not subscriptable
tests/python3.8/boto_tests/test_signers.py:227: TypeError
_________________________________________________________________ test_testsigner_generate_presigned_post __________________________________________________________________
base_signer_setup_s3v4 =
@pytest.mark.moto
@pytest.mark.asyncio
async def test_testsigner_generate_presigned_post(
base_signer_setup_s3v4: dict,
):
auth_cls = mock.Mock()
auth_cls.REQUIRES_REGION = True
request_dict = {
'headers': {},
'url': 'https://s3.amazonaws.com/mybucket',
'body': b'',
'url_path': '/',
'method': 'POST',
'context': {},
}
with mock.patch.dict(
botocore.auth.AUTH_TYPE_MAPS, {'s3v4-presign-post': auth_cls}
):
> signer = base_signer_setup_s3v4['signer']
E TypeError: 'coroutine' object is not subscriptable
tests/python3.8/boto_tests/test_signers.py:262: TypeError
============================================================================= warnings summary =============================================================================
tests/conftest.py:25
/home/tkloczko/rpmbuild/BUILD/aiobotocore-2.4.0/tests/conftest.py:25: PytestRemovedIn8Warning: The pytest_cmdline_preparse hook is deprecated and will be removed in a future release.
Please use pytest_load_initial_conftests hook instead.
def pytest_cmdline_preparse(args):
tests/test_config.py::test_connector_args
/home/tkloczko/rpmbuild/BUILD/aiobotocore-2.4.0/tests/test_config.py:52: DeprecationWarning: The object should be created within an async function
AioConfig({"resolver": aiohttp.resolver.DefaultResolver()})
tests/boto_tests/test_utils.py::test_idmsfetcher_retry
/usr/lib/python3.8/site-packages/botocore/awsrequest.py:606: RuntimeWarning: coroutine 'fake_aiohttp_session..FakeAioHttpSession.FakeResponse._content' was never awaited
self.update(*args, **kwargs)
Enable tracemalloc to get traceback where the object was allocated.
See https://docs.pytest.org/en/stable/how-to/capture-warnings.html#resource-warnings for more info.
tests/boto_tests/test_utils.py::test_idmsfetcher_retry
/usr/lib/python3.8/site-packages/botocore/awsrequest.py:606: RuntimeWarning: coroutine 'fake_aiohttp_session..FakeAioHttpSession.FakeResponse._text' was never awaited
self.update(*args, **kwargs)
Enable tracemalloc to get traceback where the object was allocated.
See https://docs.pytest.org/en/stable/how-to/capture-warnings.html#resource-warnings for more info.
tests/python3.8/test_eventstreams.py::test_kinesis_stream_json_parser
/usr/lib/python3.8/site-packages/botocore/hooks.py:470: RuntimeWarning: coroutine 'fake_aiohttp_session..FakeAioHttpSession.FakeResponse._text' was never awaited
event_parts[event_parts.index(old_part)] = new_part
Enable tracemalloc to get traceback where the object was allocated.
See https://docs.pytest.org/en/stable/how-to/capture-warnings.html#resource-warnings for more info.
tests/python3.8/test_eventstreams.py::test_kinesis_stream_json_parser
/usr/lib/python3.8/site-packages/botocore/hooks.py:470: RuntimeWarning: coroutine 'fake_aiohttp_session..FakeAioHttpSession.FakeResponse._content' was never awaited
event_parts[event_parts.index(old_part)] = new_part
Enable tracemalloc to get traceback where the object was allocated.
See https://docs.pytest.org/en/stable/how-to/capture-warnings.html#resource-warnings for more info.
tests/python3.8/boto_tests/test_utils.py::TestInstanceMetadataFetcher::test_disabling_env_var_not_true
/usr/lib64/python3.8/linecache.py:65: RuntimeWarning: coroutine 'base_signer_setup' was never awaited
for filename in filenames:
Enable tracemalloc to get traceback where the object was allocated.
See https://docs.pytest.org/en/stable/how-to/capture-warnings.html#resource-warnings for more info.
tests/python3.8/boto_tests/test_utils.py::TestInstanceMetadataFetcher::test_disabling_env_var_not_true
/usr/lib64/python3.8/linecache.py:65: RuntimeWarning: coroutine 'base_signer_setup_s3v4' was never awaited
for filename in filenames:
Enable tracemalloc to get traceback where the object was allocated.
See https://docs.pytest.org/en/stable/how-to/capture-warnings.html#resource-warnings for more info.
tests/python3.8/boto_tests/test_utils.py::test_containermetadatafetcher_retrieve_url_bad_status
/usr/lib64/python3.8/inspect.py:2177: RuntimeWarning: coroutine 'fake_aiohttp_session..FakeAioHttpSession.FakeResponse._text' was never awaited
parameters.append(Parameter(name, annotation=annotation,
Enable tracemalloc to get traceback where the object was allocated.
See https://docs.pytest.org/en/stable/how-to/capture-warnings.html#resource-warnings for more info.
tests/python3.8/boto_tests/test_utils.py::test_containermetadatafetcher_retrieve_url_not_json
/usr/lib64/python3.8/unittest/mock.py:2076: RuntimeWarning: coroutine 'fake_aiohttp_session..FakeAioHttpSession.FakeResponse._text' was never awaited
self.name = name
Enable tracemalloc to get traceback where the object was allocated.
See https://docs.pytest.org/en/stable/how-to/capture-warnings.html#resource-warnings for more info.
-- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html
========================================================================= short test summary info ==========================================================================
SKIPPED [1] tests/test_basic_s3.py:415: Not supported
ERROR tests/test_basic_s3.py::test_paginate_max_items - AttributeError: 'async_generator' object has no attribute 'abort_multipart_upload'
ERROR tests/test_sns.py::test_topic_attributes - AttributeError: 'async_generator' object has no attribute 'create_topic'
ERROR tests/test_sns.py::test_topic_attributes - AttributeError: 'async_generator' object has no attribute 'delete_topic'
ERROR tests/test_sns.py::test_creating_subscription - AttributeError: 'async_generator' object has no attribute 'create_topic'
ERROR tests/test_sns.py::test_creating_subscription - AttributeError: 'async_generator' object has no attribute 'delete_topic'
ERROR tests/test_sns.py::test_publish_to_http - AttributeError: 'async_generator' object has no attribute 'create_topic'
ERROR tests/test_sns.py::test_publish_to_http - AttributeError: 'async_generator' object has no attribute 'delete_topic'
ERROR tests/boto_tests/test_credentials.py::test_load_sso_credentials_without_cache
FAILED tests/test_basic_s3.py::test_can_make_request - AttributeError: 'async_generator' object has no attribute 'list_buckets'
FAILED tests/test_basic_s3.py::test_can_make_request_no_verify[False] - AttributeError: 'async_generator' object has no attribute 'list_buckets'
FAILED tests/test_basic_s3.py::test_fail_proxy_request - AttributeError: 'async_generator' object has no attribute 'list_buckets'
FAILED tests/test_basic_s3.py::test_succeed_proxy_request[False] - AttributeError: 'async_generator' object has no attribute 'list_buckets'
FAILED tests/test_basic_s3.py::test_can_get_bucket_location - AttributeError: 'async_generator' object has no attribute 'get_bucket_location'
FAILED tests/test_basic_s3.py::test_can_delete_urlencoded_object - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_can_paginate - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_can_paginate_with_page_size - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_can_search_paginate - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_can_paginate_iterator - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_result_key_iters - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_can_get_and_put_object - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_adaptive_retry - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_get_object_stream_wrapper - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_get_object_stream_context - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_paginate_max_items - AttributeError: 'async_generator' object has no attribute 'create_multipart_upload'
FAILED tests/test_basic_s3.py::test_paginate_within_page_boundaries - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_unicode_key_put_list[False] - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_unicode_system_character[False] - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_non_normalized_key_paths - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_copy_with_quoted_char - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_copy_with_query_string - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_can_copy_with_dict_form - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_can_copy_with_dict_form_with_version - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_copy_with_s3_metadata - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_presign_with_existing_query_string_values[False-s3-us-east-1] - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_presign_sigv4[False-s3v4-us-east-1] - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_can_follow_signed_url_redirect[False-s3v4] - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_basic_s3.py::test_bucket_redirect[False-us-west-2-eu-west-1] - TypeError: 'async_generator' object is not callable
FAILED tests/test_basic_s3.py::test_head_object_keys[s3v4] - AttributeError: 'async_generator' object has no attribute 'put_object'
FAILED tests/test_batch.py::test_batch - AttributeError: 'async_generator' object has no attribute 'describe_job_queues'
FAILED tests/test_dynamodb.py::test_get_item[v4] - AttributeError: 'async_generator' object has no attribute 'put_item'
FAILED tests/test_dynamodb.py::test_create_waiter[v4] - AttributeError: 'async_generator' object has no attribute 'create_table'
FAILED tests/test_dynamodb.py::test_batch_write_scan[v4] - AttributeError: 'async_generator' object has no attribute 'batch_write_item'
FAILED tests/test_dynamodb.py::test_delete_table[v4] - AttributeError: 'async_generator' object has no attribute 'create_table'
FAILED tests/test_dynamodb.py::test_waiter_table_exists_failure[v4] - AttributeError: 'async_generator' object has no attribute 'get_waiter'
FAILED tests/test_dynamodb.py::test_waiter_table_exists[v4] - AttributeError: 'async_generator' object has no attribute 'get_waiter'
FAILED tests/test_ec2.py::test_ec2_snapshot - AttributeError: 'async_generator' object has no attribute 'create_volume'
FAILED tests/test_eventstreams.py::test_eventstream_chunking - AttributeError: 'async_generator' object has no attribute '_service_model'
FAILED tests/test_eventstreams.py::test_eventstream_no_iter - AttributeError: 'async_generator' object has no attribute '_service_model'
FAILED tests/test_lambda.py::test_run_lambda - AttributeError: 'async_generator' object has no attribute 'get_role'
FAILED tests/test_monitor.py::test_monitor_response_received - AttributeError: 'async_generator' object has no attribute 'meta'
FAILED tests/test_mturk.py::test_mturk_stubber - botocore.exceptions.ConnectTimeoutError: Connect timeout on endpoint URL: "http://169.254.169.254/latest/api/token"
FAILED tests/test_patches.py::test_patches - assert False
FAILED tests/test_sns.py::test_get_missing_endpoint_attributes - AttributeError: 'async_generator' object has no attribute 'get_endpoint_attributes'
FAILED tests/test_sns.py::test_platform_applications - AttributeError: 'async_generator' object has no attribute 'create_platform_application'
FAILED tests/test_sqs.py::test_list_queues - AttributeError: 'async_generator' object has no attribute 'list_queues'
FAILED tests/test_sqs.py::test_get_queue_name - AttributeError: 'async_generator' object has no attribute 'rsplit'
FAILED tests/test_sqs.py::test_put_pull_delete_test - AttributeError: 'async_generator' object has no attribute 'send_message'
FAILED tests/test_sqs.py::test_put_pull_wait - AttributeError: 'async_generator' object has no attribute 'receive_message'
FAILED tests/test_waiter.py::test_sqs - AttributeError: 'async_generator' object has no attribute 'create_stack'
FAILED tests/boto_tests/test_credentials.py::test_get_credentials - botocore.exceptions.EndpointConnectionError: Could not connect to the endpoint URL: "http://[fd00:ec2...
FAILED tests/boto_tests/test_credentials.py::test_sso_credential_fetcher_can_fetch_credentials - AttributeError: 'async_generator' object has no attribute 'role_name'
FAILED tests/boto_tests/test_credentials.py::test_sso_cred_fetcher_raises_helpful_message_on_unauthorized_exception - AttributeError: 'async_generator' object has no att...
FAILED tests/boto_tests/test_credentials.py::test_load_sso_credentials_with_cache - AttributeError: 'async_generator' object has no attribute 'expires_at'
FAILED tests/boto_tests/test_credentials.py::test_load_sso_credentials_with_cache_expired - AttributeError: 'async_generator' object has no attribute 'cache'
FAILED tests/boto_tests/test_credentials.py::test_required_config_not_set - AttributeError: 'async_generator' object has no attribute 'config'
FAILED tests/boto_tests/test_signers.py::test_signers_generate_db_auth_token - AttributeError: 'async_generator' object has no attribute 'meta'
FAILED tests/python3.8/test_eventstreams.py::test_kinesis_stream_json_parser - AttributeError: 'async_generator' object has no attribute 'enter_async_context'
FAILED tests/python3.8/boto_tests/test_signers.py::test_testsigner_get_auth - TypeError: 'coroutine' object is not subscriptable
FAILED tests/python3.8/boto_tests/test_signers.py::test_testsigner_region_required_for_sig4 - TypeError: 'coroutine' object is not subscriptable
FAILED tests/python3.8/boto_tests/test_signers.py::test_testsigner_custom_sign_version - TypeError: 'coroutine' object is not subscriptable
FAILED tests/python3.8/boto_tests/test_signers.py::test_testsigner_choose_signer_override - TypeError: 'coroutine' object is not subscriptable
FAILED tests/python3.8/boto_tests/test_signers.py::test_testsigner_generate_presigned_url - TypeError: 'coroutine' object is not subscriptable
FAILED tests/python3.8/boto_tests/test_signers.py::test_testsigner_generate_presigned_post - TypeError: 'coroutine' object is not subscriptable
==================================================== 65 failed, 112 passed, 1 skipped, 10 warnings, 8 errors in 14.21s =====================================================
```
thehesiod
yan12125
Describe the bug A clear and concise description of what the bug is.
Checklist
pip checkpasses without errorspip freezeresultspip freeze results
Environment:
Additional context I'm packaging your module as an rpm package so I'm using the typical PEP517 based build, install and test cycle used on building packages from non-root account.
python3 -sBm build -w --no-isolationbuildwith--no-isolationI'm using during all processes only locally installed modulesBecaus eone unit is failing on missing fixture I'm assuming that at least one module is missing in my build env. May I ask fo rdome hints what may be missing?