fix tests

Author: liferoad

sdks/python/apache_beam/io/gcp/pubsub.py

@@ -577,7 +577,7 @@ def __init__(self, transform):
 
       # Check if using DirectRunner
       runner_name = getattr(pipeline_options, 'runner', None)
-      if runner_name and 'DirectRunner' in str(runner_name):
+      if runner_name is None or 'DirectRunner' in str(runner_name):
         should_raise_error = True
 
       # Check if in batch mode (not streaming)