julee.services.temporal.activities

Temporal activity wrapper classes for the julee knowledge service domain.

This module contains the @temporal_activity_registration decorated class that wraps knowledge service operations as Temporal activities. This class is imported by the worker to register activities with Temporal.

The class follows the naming pattern documented in systemPatterns.org: - Activity names: {domain}.{service_name}.{method} - The knowledge service gets its own activity prefix

Attributes

KNOWLEDGE_SERVICE_ACTIVITY_BASE

Classes

TemporalKnowledgeService

Temporal activity wrapper for KnowledgeService operations.

Module Contents

class julee.services.temporal.activities.TemporalKnowledgeService(document_repo)

Bases: julee.services.knowledge_service.factory.ConfigurableKnowledgeService

Temporal activity wrapper for KnowledgeService operations.

This class handles the issue where ContentStream objects don’t survive Temporal’s serialization by re-fetching document content from the injected DocumentRepository before performing operations that require it.

async register_file(config, document)

Register a document file, re-fetching content if needed.

This method checks if the document’s ContentStream is None (due to Temporal serialization) and re-fetches content from MinIO if needed.

document_repo: julee.domain.repositories.document.DocumentRepository

logger: logging.Logger

julee.services.temporal.activities.KNOWLEDGE_SERVICE_ACTIVITY_BASE = 'julee.knowledge_service'