fix: normalize ThoughtSpot TML import object responses

tests/test_liveboard_creation_context.py

@@ -147,3 +147,4 @@ def test_tml_504_recovery_verifies_state_before_retrying_full_payload():
     assert "retrying full {retry_kind} payload once" in source
     assert "connection_fqn=connection_fqn" in source
     assert "wait_for_model_answer_ready" in source
+    assert 'if "status" in obj or "header" in obj' in source

thoughtspot_deployer.py

@@ -2346,18 +2346,31 @@ class ThoughtSpotDeployer:
             batch1_start = time.time()
             log_progress(f"Batch 1/2: Creating {table_count} tables...")
 
+            def _normalize_tml_import_object(obj):
+                if not isinstance(obj, dict):
+                    return obj
+                if "response" in obj:
+                    return obj
+                if "status" in obj or "header" in obj:
+                    return {"response": obj}
+                return obj
+
             def _normalize_tml_import_objects(result):
                 if isinstance(result, list):
-                    return result
+                    return [_normalize_tml_import_object(obj) for obj in result]
                 if isinstance(result, dict) and 'object' in result:
-                    return result['object']
+                    return [_normalize_tml_import_object(obj) for obj in result['object']]
                 return None
 
             def _tml_objects_by_name(expected_names, objects):
                 named = {}
                 for idx, obj in enumerate(objects or []):
                     header = obj.get('response', {}).get('header', {}) if isinstance(obj, dict) else {}
-                    raw_name = header.get('name') or header.get('display_name')
+                    raw_name = (
+                        header.get('name')
+                        or header.get('display_name')
+                        or header.get('displayName')
+                    )
                     table_name = (raw_name or (expected_names[idx] if idx < len(expected_names) else f"TABLE_{idx}")).upper()
                     named[table_name] = obj
                 return named
@@ -2449,12 +2462,23 @@ class ThoughtSpotDeployer:
                     object_count = len(objects) if isinstance(objects, list) else 0
                     object_statuses = []
                     object_names = []
+                    object_errors = []
                     for obj in objects or []:
                         obj_response = obj.get('response', {}) if isinstance(obj, dict) else {}
                         status = obj_response.get('status', {})
                         header = obj_response.get('header', {})
                         object_statuses.append(status.get('status_code'))
-                        object_names.append(header.get('name') or header.get('display_name'))
+                        object_names.append(header.get('name') or header.get('display_name') or header.get('displayName'))
+                        if status.get('error_message'):
+                            object_errors.append(str(status.get('error_message'))[:300])
+                    status_summary = ", ".join(str(status) for status in object_statuses if status)
+                    if status_summary:
+                        log_progress(
+                            f"   {phase_label}: response objects={object_count}; "
+                            f"statuses={status_summary}"
+                        )
+                    if object_errors:
+                        log_progress(f"   {phase_label}: first object error: {object_errors[0]}")
                     if _slog:
                         _slog.log(
                             "thoughtspot",
@@ -2465,6 +2489,7 @@ class ThoughtSpotDeployer:
                             object_count=object_count,
                             object_statuses=object_statuses,
                             object_names=[name for name in object_names if name],
+                            object_errors=object_errors[:5],
                         )
                     if objects is None:
                         error = f"{phase_label} failed: Unexpected response format: {type(response_json)}"