diff --git a/gce/cron_executor.py b/gce/cron_executor.py
index c9ce3d2..eaa4ab1 100644
--- a/gce/cron_executor.py
+++ b/gce/cron_executor.py
@@ -231,8 +231,15 @@ def process_messages(self, msgs):
 
     def watch_topic(self):
         while True:
-            msgs = self.get_messages()
-            if msgs:
+            msgs = None
+            try:
+                msgs = self.get_messages()       
+            except Error:
+                log.error('Failed to get messages.')
+
+            if (msgs != None):                      
                 self.process_messages(msgs)
+            else:
+                log.error('Skipping processing message.')
             # when return immediately is False-  there is about a 90second open
             # request