fix: time based state refresh for each activity

application_sdk/activities/__init__.py

@@ -140,8 +140,8 @@ async def _get_state(self, workflow_args: Dict[str, Any]) -> ActivitiesStateType
         """
         try:
             workflow_id = get_workflow_id()
-            if workflow_id not in self._state:
-                await self._set_state(workflow_args)
+            await self._clean_state()
+            await self._set_state(workflow_args)
             return self._state[workflow_id]
         except OrchestratorError as e:
             logger.error(