def _create_test_message():
 sqs = SQSConnection()
 sqs_q = sqs.get_queue(g.sitemap_sqs_queue)
 assert sqs_q, 'failed to connect to queue'
 message = sqs_q.new_message(body=json.dumps({'job_name': 'daily-sr-sitemap-reporting', 'location': ('s3://reddit-data-analysis/big-data/r2/prod/' + 'daily_sr_sitemap_reporting/dt=2016-06-14'), 'timestamp': _current_timestamp()}))
 sqs_q.write(message)

def _create_test_message ( ) : sqs = SQSConnection ( ) sqs_q = sqs . get_queue ( g . sitemap_sqs_queue ) assert sqs_q , 'failed to connect to queue' message = sqs_q . new_message ( body = json . dumps ( { 'job_name' : 'daily-sr-sitemap-reporting' , 'location' : ( 's3://reddit-data-analysis/big-data/r2/prod/' + 'daily_sr_sitemap_reporting/dt=2016-06-14' ) , 'timestamp' : _current_timestamp ( ) } ) ) sqs_q . write ( message )
a dev only function that drops a new message on the sqs queue .