fix: TypeError in agent announcement process

- Add type check in fsm.py to ensure payload is a dictionary before passing to set_from
- Add defensive check in host.py to verify required keys exist in announce response
- Prevents "'bool' object is not subscriptable" error in confluent_kafka tests

Signed-off-by: Paulo Vital <[email protected]>

Author: pvital

src/instana/agent/host.py

@@ -138,10 +138,15 @@ def set_from(
         @return: None
         """
         self.options.set_from(res_data)
-        self.announce_data = AnnounceData(
-            pid=res_data["pid"],
-            agentUuid=res_data["agentUuid"],
-        )
+
+        # Ensure required keys are present
+        if "pid" in res_data and "agentUuid" in res_data:
+            self.announce_data = AnnounceData(
+                pid=res_data["pid"],
+                agentUuid=res_data["agentUuid"],
+            )
+        else:
+            logger.debug(f"Missing required keys in announce response: {res_data}")
 
     def get_from_structure(self) -> Dict[str, str]:
         """

src/instana/fsm.py

@@ -148,7 +148,7 @@ def announce_sensor(self, e: Any) -> bool:
 
         payload = self.agent.announce(d)
 
-        if not payload:
+        if not payload or not isinstance(payload, dict):
             logger.debug("Cannot announce sensor. Scheduling retry.")
             self.schedule_retry(
                 self.announce_sensor, e, f"{self.THREAD_NAME}: announce"