lib/flydata/query_based_sync/client.rb in flydata-0.7.11 vs lib/flydata/query_based_sync/client.rb in flydata-0.7.12

@@ -61,14 +61,23 @@
           run_once
           break if stop_requested?
           sleep @fetch_interval
         end
       rescue => e
-        #TODO: Introduce retryable error notions
-        log_error_with_backtrace("Unexpected error occured", error: e)
+        handle_error(e, "Unexpected error occured")
         sleep @retry_interval
         retry
       end
+    end
+
+    def handle_error(error, message)
+      log_method = if error.kind_of?(FlydataCore::RetryableError)
+                     error = error.original_exception
+                     :log_warn
+                   else
+                     :log_error
+                   end
+      self.send(log_method, message, {error: error}, {backtrace: true})
     end
 
     def run_once
       resource_requester.start do |req|  # open connection
         context.tables.each do |table_name|