← Back to branch summary

~daisy-pluckers/daisy/trunk

« back to all changes in this revision

Viewing changes to daisy/submit.py

  • Committer: Brian Murray
  • Date: 2019-08-07 17:13:14 UTC
  • Revision ID: brian@canonical.com-20190807171314-dfp24a3nctm4ft9u
pass a cassandra session to oops-repository so it is not creating a new session

Show diffs side-by-side

added added

removed removed

Lines of Context:
daisy/submit.py
313
313
        return (False, 'Device blocked from sending crash reports.')
314
314
 
315
315
    try:
316
 
        oopses.insert_dict(oops_config, oops_id, data, system_token, fields,
 
316
        oopses.insert_dict(_session, oops_id, data, system_token, fields,
317
317
                           proposed_pkg=package_from_proposed)
318
318
    except WriteTimeout:
319
319
        msg = "%s: WriteTimeout with %s keys." % \
349
349
    crash_signature = report.get('DuplicateSignature')
350
350
    if crash_signature:
351
351
        crash_signature = utils.format_crash_signature(crash_signature)
352
 
        utils.bucket(oops_config, oops_id, crash_signature, data)
 
352
        utils.bucket(_session, oops_id, crash_signature, data)
353
353
        metrics.meter('success.duplicate_signature')
354
354
        return (True, '%s OOPSID' % oops_id)
355
355
 
363
363
                            % ('OOPS', hex_oopsid, cql_crash_sig)))
364
364
        formatted_crash_sig = utils.format_crash_signature(crash_signature)
365
365
        cql_formatted_crash_sig = formatted_crash_sig.replace("'", "''")
366
 
        utils.bucket(oops_config, oops_id, cql_formatted_crash_sig, data)
 
366
        utils.bucket(_session, oops_id, cql_formatted_crash_sig, data)
367
367
        metrics.meter('success.python_bucketed')
368
368
        return (True, '%s OOPSID' % oops_id)
369
369
 
433
433
                                     [oops_id, unneeded_column])
434
434
            # We have already retraced for this address signature, so this
435
435
            # crash can be immediately bucketed.
436
 
            utils.bucket(oops_config, oops_id, crash_sig, data)
 
436
            utils.bucket(_session, oops_id, crash_sig, data)
437
437
            metrics.meter('success.ready_binary_bucketed')
438
438
            if arch:
439
439
                metrics.meter('success.ready_binary_bucketed.%s' % arch)