simplify

Author: eugeniaguerrero

src/agentex/lib/cli/templates/temporal/README.md.j2

@@ -283,6 +283,9 @@ result = await workflow.execute_activity(
     heartbeat_timeout=timedelta(minutes=1),         # Optional: heartbeat monitoring
     retry_policy=RetryPolicy(maximum_attempts=3)    # Optional: retry policy
 )
+
+# Don't forget to register your custom activities in run_worker.py:
+# all_activities = get_all_activities() + [your_custom_activity_function]
 ```
 
 ### Integration with External Services

src/agentex/lib/cli/templates/temporal/project/run_worker.py.j2

@@ -1,7 +1,4 @@
 import asyncio
-import importlib.util
-import sys
-from pathlib import Path
 
 from agentex.lib.core.temporal.activities import get_all_activities
 from agentex.lib.core.temporal.workers.worker import AgentexWorker
@@ -17,29 +14,6 @@ environment_variables = EnvironmentVariables.refresh()
 logger = make_logger(__name__)
 
 
-def load_custom_activities():
-    """Load custom activities from project/activities.py if it exists"""
-    activities_path = Path(__file__).parent / "activities.py"
-    custom_activities = []
-    
-    if activities_path.exists():
-        logger.info(f"Loading custom activities from {activities_path}")
-        spec = importlib.util.spec_from_file_location("project.activities", activities_path)
-        if spec and spec.loader:
-            module = importlib.util.module_from_spec(spec)
-            sys.modules["project.activities"] = module
-            spec.loader.exec_module(module)
-            
-            # Find all activity functions (decorated with @activity.defn)
-            for name in dir(module):
-                obj = getattr(module, name)
-                if callable(obj) and hasattr(obj, "__temporal_activity_definition__"):
-                    custom_activities.append(obj)
-                    logger.info(f"  - Registered custom activity: {name}")
-    
-    return custom_activities
-
-
 async def main():
     # Setup debug mode if enabled
     setup_debug_if_enabled()
@@ -48,10 +22,7 @@ async def main():
     if task_queue_name is None:
         raise ValueError("WORKFLOW_TASK_QUEUE is not set")
 
-    # Load all activities (both core and custom)
-    all_activities = get_all_activities()
-    custom_activities = load_custom_activities()
-    all_activities.extend(custom_activities)
+    all_activities = get_all_activities() + []  # add your own activities here
 
     # Create a worker with automatic tracing
     worker = AgentexWorker(