KOALA-3922: Update documentation

Author: irfan-vicert

collections/_sdk/effects/data_integration.md

@@ -53,21 +53,18 @@ from canvas_sdk.effects.data_integration import AssignDocumentReviewer, Priority
 from canvas_sdk.events import EventType
 from canvas_sdk.protocols import BaseProtocol
 
-from canvas_sdk.v1.data.integration_task import IntegrationTask
 from canvas_sdk.v1.data.staff import Staff
 
 
 class Protocol(BaseProtocol):
-    RESPONDS_TO = [
-        EventType.Name(EventType.INTEGRATION_TASK_CREATED),
-    ]
+    RESPONDS_TO = EventType.Name(EventType.DOCUMENT_RECEIVED)
 
     def compute(self) -> list[Effect]:
-        integration_task = IntegrationTask.objects.get(id=self.target)
+        document_id = self.event.context.get("document", {}).get("id")
         reviewer = Staff.objects.get(last_name="Smith")
 
         assign_reviewer = AssignDocumentReviewer(
-            document_id=integration_task.id,
+            document_id=document_id,
             reviewer_id=reviewer.id,
             priority=Priority.NORMAL,
             review_mode=ReviewMode.REVIEW_REQUIRED,
@@ -84,21 +81,18 @@ from canvas_sdk.effects.data_integration import AssignDocumentReviewer, Priority
 from canvas_sdk.events import EventType
 from canvas_sdk.protocols import BaseProtocol
 
-from canvas_sdk.v1.data.integration_task import IntegrationTask
 from canvas_sdk.v1.data.team import Team
 
 
 class Protocol(BaseProtocol):
-    RESPONDS_TO = [
-        EventType.Name(EventType.INTEGRATION_TASK_CREATED),
-    ]
+    RESPONDS_TO = EventType.Name(EventType.DOCUMENT_RECEIVED)
 
     def compute(self) -> list[Effect]:
-        integration_task = IntegrationTask.objects.get(id=self.target)
+        document_id = self.event.context.get("document", {}).get("id")
         team = Team.objects.get(name="Document Review")
 
         assign_reviewer = AssignDocumentReviewer(
-            document_id=integration_task.id,
+            document_id=document_id,
             team_id=team.id,
             priority=Priority.HIGH,
         )