Action scheduler refactored (#1471)

* 1. action scheduler refactored
2. library updated

* library updated

* library updated

* 1. sso default signature fixed
2. schedule action id fixed

* 1. sso default signature fixed
2. schedule action id fixed

kairon/actions/definitions/schedule.py

@@ -153,7 +153,7 @@ async def add_schedule_job(self,
             'func': func,
             'args': tuple(args) if args is not None else (),
             'kwargs': dict(kwargs) if kwargs is not None else {},
-            '_id': _id,
+            'id': _id,
             'name': "execute_task",
             'misfire_grace_time': 7200,
             'coalesce': True,

kairon/shared/sso/clients/kairon.py

@@ -1,5 +1,5 @@
 import ujson as json
-from typing import Optional, Dict, Any
+from typing import Optional, Dict, Any, Union, Literal
 from loguru import logger as logging
 import httpx
 from fastapi_sso.sso.base import SSOBase, OpenID
@@ -9,8 +9,15 @@
 class KaironSSO(SSOBase):
 
     async def process_login(
-            self, code: str, request: Request, *, params: Optional[Dict[str, Any]] = None,
-            additional_headers: Optional[Dict[str, Any]] = None, redirect_uri: Optional[str] = None
+            self,
+            code: str,
+            request: Request,
+            *,
+            params: Optional[Dict[str, Any]] = None,
+            additional_headers: Optional[Dict[str, Any]] = None,
+            redirect_uri: Optional[str] = None,
+            pkce_code_verifier: Optional[str] = None,
+            convert_response: Union[Literal[True], Literal[False]] = True,
     ) -> Optional[OpenID]:
         """This method should be called from callback endpoint to verify the user and request user info endpoint.
         This is low level, you should use {verify_and_process} instead.

kairon/shared/sso/clients/linkedin.py

@@ -59,7 +59,8 @@ async def get_discovery_document(cls) -> Dict[str, str]:
         }
 
     async def process_login(
-            self, code: str,
+            self,
+            code: str,
             request: Request,
             *,
             params: Optional[Dict[str, Any]] = None,