"""SQS resource. Provides boto3 Queue resource for sending messages to SQS. """ import boto3 from masters_registry import config sqs_resource = boto3.resource('sqs') queue_yt_ownership = None if config.ENVIRONMENT != config.TEST_ENVIRONMENT: queue_yt_ownership = sqs_resource.get_queue_by_name( QueueName=config.QUEUE_NAME_YT_OWNERSHIP)