From c83dae28fc0b79f30c1775b55a3bdf1551206947 Mon Sep 17 00:00:00 2001 From: Bryan Moyles Date: Tue, 13 Mar 2018 14:28:05 -0400 Subject: [PATCH] Wrap pod callback for pod and container metadata with a try/catch. --- src/kubernetes.cc | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/src/kubernetes.cc b/src/kubernetes.cc index eabb2c5c..1f5bfd3d 100644 --- a/src/kubernetes.cc +++ b/src/kubernetes.cc @@ -1049,9 +1049,13 @@ void KubernetesReader::PodCallback( MetadataUpdater::UpdateCallback callback, const json::Object* pod, Timestamp collected_at, bool is_deleted) const throw(json::Exception) { - std::vector result_vector = - GetPodAndContainerMetadata(pod, collected_at, is_deleted); - callback(std::move(result_vector)); + try { + std::vector result_vector = + GetPodAndContainerMetadata(pod, collected_at, is_deleted); + callback(std::move(result_vector)); + } catch (const json::Exception& e) { + LOG(ERROR) << e.what(); + } } void KubernetesReader::WatchPods(MetadataUpdater::UpdateCallback callback)