diff --git a/batch_import.py b/batch_import.py
index 51e5894..965e20b 100644
--- a/batch_import.py
+++ b/batch_import.py
@@ -71,7 +71,7 @@ def main(instance_id, database_id):
   # Create the database.
   ddl_statements = open('schema.ddl', 'r').read().split(';')
   database = instance.database(database_id, ddl_statements=ddl_statements)
-  database.create()
+  database.create().result()  # Wait for operation to complete.
 
   # File paths.
   comments_file = 'hnewscomments.csv'