3b84c35aaf6f585222e54e77696ecab639b14692,dlp/risk.py,,k_map_estimate_analysis,#,529

Before Change

            raise

    // Register the callback and wait on the event.
    subscription.open(callback)
    finished = job_done.wait(timeout=timeout)
    if not finished:
        print("No event received before the timeout. Please verify that the "
              "subscription provided is subscribed to the topic provided.")

After Change

    // Call API to start risk analysis job
    operation = dlp.create_dlp_job(parent, risk_job=risk_job)

    try:
        subscription.result(timeout=timeout)
    except TimeoutError:
        print("No event received before the timeout. Please verify that the "
              "subscription provided is subscribed to the topic provided.")
        subscription.close()
// [END dlp_k_map]


if __name__ == "__main__":
    parser = argparse.ArgumentParser(description=__doc__)
    subparsers = parser.add_subparsers(
        dest="content", help="Select how to submit content to the API.")

Instances