8000 Kinesis: SubscribeToShard session cut after 5min by ackdav · Pull Request #6732 · localstack/localstack · GitHub
[go: up one dir, main page]
Skip to content

Kinesis: SubscribeToShard session cut after 5min #6732

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 9 commits into from
Aug 28, 2022
Merged

Kinesis: SubscribeToShard session cut after 5min #6732

Changes from 1 commit
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
5a3d88a
added aws_validated for tests, moved shard iterator test within class
ackdav Aug 23, 2022
dd5fa99
added test for adding tags to stream
ackdav Aug 23, 2022
0ed3c41
fixes an early timeout in kinesis subscribe_to_shard mentioned in #58…
ackdav Aug 23, 2022
2d07032
correcting linting using black
ackdav Aug 23, 2022
2520052
converted 3 tests to snapshots, streamlined streamname creating acros…
ackdav Aug 25, 2022
061936a
kinesis sending empty records every few seconds
ackdav Aug 26, 2022
2427f38
update snapshot, reformatting, removing stub, convert tests to snapshot
ackdav Aug 26, 2022
669afba
correct patch to 3 secs
ackdav Aug 26, 2022
670c5cb
reworded empty results in subscribe to shard
ackdav Aug 26, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
added test for adding tags to stream
  • Loading branch information
@ackdav @thrau
ackdav authored and thrau committed Aug 27, 2022
commit dd5fa99f51ef2b0f09e423f04e25e5b466256893
24 changes: 24 additions & 0 deletions tests/integration/test_kinesis.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,12 +1,15 @@
import json
import logging
import re
import time
from datetime import datetime

import cbor2
import pytest
import requests

from localstack import config, constants
from localstack.services.kinesis import kinesis_listener
from localstack.utils.aws import aws_stack
from localstack.utils.common import poll_condition, retry, select_attributes, short_uid
from localstack.utils.kinesis import kinesis_connector
Expand Down Expand Up @@ -309,6 +312,27 @@ def test_record_lifecycle_data_integrity(
for response_record in response_records:
assert response_record.get("Data").decode("utf-8") in records_data

@pytest.mark.aws_validated
def test_add_tags_to_stream(self, kinesis_client, kinesis_create_stream, wait_for_stream_ready):
stream_name = "test-%s" % short_uid()
test_tags = {
"Hello": "world"
}

# create stream
kinesis_create_stream(StreamName=stream_name, ShardCount=1)
wait_for_stream_ready(stream_name)

# adding tags
kinesis_client.add_tags_to_stream(StreamName=stream_name, Tags=test_tags)

# reading stream tags
list_tags_response = kinesis_client.list_tags_for_stream(StreamName=stream_name)

assert list_tags_response['Tags'][0]['Key'] == "Hello"
assert list_tags_response['Tags'][0]['Value'] == test_tags["Hello"]
assert not list_tags_respons 4A76 e['HasMoreTags']

@pytest.mark.aws_validated
def test_get_records_next_shard_iterator(
self, kinesis_client, kinesis_create_stream, wait_for_stream_ready
Expand Down
0