julee.services.temporal.activities
==================================

.. py:module:: julee.services.temporal.activities

.. autoapi-nested-parse::

   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
----------

.. autoapisummary::

   julee.services.temporal.activities.KNOWLEDGE_SERVICE_ACTIVITY_BASE


Classes
-------

.. autoapisummary::

   julee.services.temporal.activities.TemporalKnowledgeService


Module Contents
---------------

.. py:class:: TemporalKnowledgeService(document_repo)

   Bases: :py:obj:`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.


   .. py:method:: register_file(config, document)
      :async:


      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.



   .. py:attribute:: document_repo
      :type:  julee.domain.repositories.document.DocumentRepository


   .. py:attribute:: logger
      :type:  logging.Logger


.. py:data:: KNOWLEDGE_SERVICE_ACTIVITY_BASE
   :value: 'julee.knowledge_service'