diff --git a/services/aiknowledge_sync_utils.py b/services/aiknowledge_sync_utils.py index 0c8f74e..dd6462d 100644 --- a/services/aiknowledge_sync_utils.py +++ b/services/aiknowledge_sync_utils.py @@ -120,12 +120,12 @@ class AIKnowledgeSync(BaseSyncUtils): # 1. Load knowledge entity knowledge = await espocrm.get_entity('CAIKnowledge', knowledge_id) - activation_status = knowledge.get('activationStatus') + activation_status = knowledge.get('aktivierungsstatus') collection_id = knowledge.get('datenbankId') ctx.logger.info("=" * 80) ctx.logger.info(f"📋 Processing: {knowledge['name']}") - ctx.logger.info(f" activationStatus: {activation_status}") + ctx.logger.info(f" aktivierungsstatus: {activation_status}") ctx.logger.info(f" datenbankId: {collection_id or 'NONE'}") ctx.logger.info("=" * 80) @@ -149,7 +149,7 @@ class AIKnowledgeSync(BaseSyncUtils): # Update EspoCRM: Set datenbankId + change status to 'active' await espocrm.update_entity('CAIKnowledge', knowledge_id, { 'datenbankId': collection_id, - 'activationStatus': AIKnowledgeActivationStatus.ACTIVE.value, + 'aktivierungsstatus': AIKnowledgeActivationStatus.ACTIVE.value, 'syncStatus': AIKnowledgeSyncStatus.UNCLEAN.value }) @@ -230,8 +230,8 @@ class AIKnowledgeSync(BaseSyncUtils): await self._sync_knowledge_documents(knowledge_id, collection_id, ctx) else: - ctx.logger.error(f"❌ Unknown activationStatus: {activation_status}") - raise ValueError(f"Invalid activationStatus: {activation_status}") + ctx.logger.error(f"❌ Unknown aktivierungsstatus: {activation_status}") + raise ValueError(f"Invalid aktivierungsstatus: {activation_status}") finally: await xai.close() diff --git a/services/document_sync_utils.py b/services/document_sync_utils.py index 7ea383c..68e0bf5 100644 --- a/services/document_sync_utils.py +++ b/services/document_sync_utils.py @@ -282,7 +282,7 @@ class DocumentSync(BaseSyncUtils): try: knowledge = await self.espocrm.get_entity('CAIKnowledge', knowledge_id) - activation_status = knowledge.get('activationStatus') + activation_status = knowledge.get('aktivierungsstatus') collection_id = knowledge.get('datenbankId') if activation_status == 'active' and collection_id: diff --git a/steps/vmh/aiknowledge_full_sync_cron_step.py b/steps/vmh/aiknowledge_full_sync_cron_step.py index ebe2ce4..b5a1294 100644 --- a/steps/vmh/aiknowledge_full_sync_cron_step.py +++ b/steps/vmh/aiknowledge_full_sync_cron_step.py @@ -38,7 +38,7 @@ async def handler(input_data: None, ctx: FlowContext[Any]) -> None: where=[ { 'type': 'equals', - 'attribute': 'activationStatus', + 'attribute': 'aktivierungsstatus', 'value': AIKnowledgeActivationStatus.ACTIVE.value }, {