File tree Expand file tree Collapse file tree 1 file changed +15
-1
lines changed
Expand file tree Collapse file tree 1 file changed +15
-1
lines changed Original file line number Diff line number Diff line change 1+ from typing import Any , Dict
2+
13from app .handler import HandlerClass
24from application_sdk .activities import ActivitiesInterface
35from application_sdk .observability .logger_adaptor import get_logger
@@ -11,4 +13,16 @@ class ActivitiesClass(ActivitiesInterface):
1113 def __init__ (self , handler : HandlerClass | None = None ):
1214 self .handler = handler or HandlerClass ()
1315
14- # Define activities here
16+ @activity .defn
17+ async def get_workflow_args (
18+ self , workflow_config : Dict [str , Any ]
19+ ) -> Dict [str , Any ]:
20+ """TODO: Process and merge workflow configuration."""
21+ return workflow_config
22+
23+ @activity .defn
24+ async def extract_and_transform_metadata (
25+ self , args : Dict [str , Any ]
26+ ) -> Dict [str , Any ]:
27+ """TODO: Implement your extraction and transformation logic."""
28+ raise NotImplementedError ("Implement this activity" )
You can’t perform that action at this time.
0 commit comments