@@ -818,12 +818,14 @@ async def _axecute(
818818 ) -> Result :
819819 """Wrapped the axecute method before returning to handler axecute.
820820
821- :param params: (DictData) A parameter data that want to use in this
822- execution.
823- :param event: (Event) An event manager that use to track parent execute
824- was not force stopped.
821+ Args:
822+ params: (DictData) A parameter data that want to use in this
823+ execution.
824+ event: (Event) An event manager that use to track parent execute
825+ was not force stopped.
825826
826- :rtype: Result
827+ Returns:
828+ Result: A Result object.
827829 """
828830 catch (context , status = WAIT )
829831 return await self .async_process (
@@ -974,14 +976,6 @@ async def _axecute(
974976 trace : Trace = get_trace (
975977 run_id , parent_run_id = parent_run_id , extras = self .extras
976978 )
977- model : Union [Self , EmptyStage ] = (
978- self .to_empty ()
979- if (
980- self .extras .get ("__sys_release_dryrun_mode" , False )
981- and self .action_stage
982- )
983- else self
984- )
985979
986980 # NOTE: First execution for not pass to retry step if it passes.
987981 try :
@@ -996,7 +990,7 @@ async def _axecute(
996990 parent_run_id = parent_run_id ,
997991 event = event ,
998992 )
999- return await model .async_process (
993+ return await self .async_process (
1000994 params | {"retry" : current_retry },
1001995 run_id = run_id ,
1002996 context = context ,
@@ -1033,7 +1027,7 @@ async def _axecute(
10331027 parent_run_id = parent_run_id ,
10341028 event = event ,
10351029 )
1036- return await model .async_process (
1030+ return await self .async_process (
10371031 params | {"retry" : current_retry },
10381032 run_id = run_id ,
10391033 context = context ,
0 commit comments