Update to use new subscribe() syntax (GoogleCloudPlatform#1989)

* Update to use new subscribe() syntax

* Missed two subscribe() call changes before

* Cancel subscription when processed

* Update risk.py

* Fix waiting for message

* Unneeded try/except removed

Author: engelke

dlp/jobs_test.py

@@ -26,7 +26,7 @@
 
 
 @pytest.fixture(scope='session')
-def create_test_job():
+def test_job_name():
     import google.cloud.dlp
     dlp = google.cloud.dlp.DlpServiceClient()
 
@@ -76,6 +76,5 @@ def test_list_dlp_jobs_with_job_type(capsys):
     assert 'Job: projects/' in out
 
 
-def test_delete_dlp_job(capsys):
-    test_job_name = create_test_job()
+def test_delete_dlp_job(test_job_name, capsys):
     jobs.delete_dlp_job(GCLOUD_PROJECT, test_job_name)

dlp/quickstart.py

@@ -59,7 +59,7 @@ def quickstart(project_id):
     }
 
     # Convert the project id into a full resource id.
-    parent = dlp_client.project_path(project)
+    parent = dlp_client.project_path(project_id)
 
     # Call the API.
     response = dlp_client.inspect_content(parent, inspect_config, item)

dlp/quickstart_test.py

@@ -29,7 +29,7 @@ def test_quickstart(capsys):
             google.cloud.dlp.DlpServiceClient,
             'project_path',
             return_value='projects/{}'.format(GCLOUD_PROJECT)):
-        quickstart.quickstart()
+        quickstart.quickstart(GCLOUD_PROJECT)
 
     out, _ = capsys.readouterr()
     assert 'FIRST_NAME' in out

dlp/requirements.txt

@@ -1,5 +1,5 @@
-google-cloud-dlp==0.9.0
-google-cloud-storage==1.13.0
-google-cloud-pubsub==0.38.0
-google-cloud-datastore==1.7.1
-google-cloud-bigquery==1.7.0
+google-cloud-dlp==0.10.0
+google-cloud-storage==1.13.2
+google-cloud-pubsub==0.39.1
+google-cloud-datastore==1.7.3
+google-cloud-bigquery==1.8.1