in src/aws_interfaces/iot_interface.py [0:0]
def delete_stream(self, streamId):
logging.info('deleting streamId %s', streamId)
try:
self.client.delete_stream(streamId=streamId)
except ClientError as e:
return False, str(e)
while True:
try:
response = self.client.describe_stream(streamId=streamId)
time.sleep(1)
except ClientError as e:
break
return True, None