Coverage for async_durable_execution/_core/__init__.py: 100%

1"""Private core runtime used by the public package facade.""" 

2 

3from .client import ( 

4 DurableServiceClient, 

5 aioboto_is_installed, 

6 create_default_async_client, 

7 create_default_sync_client, 

8 httpx_is_installed, 

9) 

10from .config import ( 

11 Duration, 

12 JitterStrategy, 

13 RetryStrategy, 

14 _DelayStrategy, 

15 duration_to_seconds, 

16) 

17from .context import ( 

18 DurableContext, 

19 OperationContext, 

20 SerDesContext, 

21 bind_current_context, 

22 bind_durable_definition, 

23 ensure_durable_operations_allowed, 

24 get_current_context, 

25 get_durable_context, 

26) 

27from .exceptions import ( 

28 CallableRuntimeError, 

29 CheckpointError, 

30 DurableExecutionsError, 

31 ExecutionError, 

32 GetExecutionStateError, 

33 InvalidStateError, 

34 InvocationError, 

35 OrphanedChildException, 

36 RetryableSerDesError, 

37 SerDesError, 

38 SuspendExecution, 

39 TerminationReason, 

40 TimedSuspendExecution, 

41 UserlandError, 

42 ValidationError, 

43 _encode_sdk_control_error_data, 

44 _register_sdk_control_error_type, 

45 _restore_sdk_control_error, 

46 suspend_with_optional_resume_delay, 

47 suspend_with_optional_resume_timestamp, 

48) 

49from .execution import ( 

50 DurableExecutionInvocationInput, 

51 InitialExecutionState, 

52 _bind_service_client_to_handler, 

53 durable_callable, 

54 durable_execution, 

55) 

56from .models import ( 

57 AwsApiModel, 

58 BotoSerializableModel, 

59 CallbackDetails, 

60 CallbackOptions, 

61 CallbackTimeoutType, 

62 ChainedInvokeDetails, 

63 ChainedInvokeOptions, 

64 CheckpointOutput, 

65 CheckpointUpdatedExecutionState, 

66 ContextDetails, 

67 ContextOptions, 

68 DurableExecutionInvocationOutput, 

69 ErrorObject, 

70 ExecutionDetails, 

71 InvocationStatus, 

72 LambdaContext, 

73 MappingModel, 

74 Operation, 

75 OperationAction, 

76 OperationIdentifier, 

77 OperationPayload, 

78 OperationStatus, 

79 OperationSubType, 

80 OperationSubTypeValue, 

81 OperationType, 

82 OperationUpdate, 

83 StateOutput, 

84 StepDetails, 

85 TimestampConverter, 

86 WaitDetails, 

87 WaitOptions, 

88) 

89from .serdes import ( 

90 ComposableSerDes, 

91 DEFAULT_JSON_SERDES, 

92 EncodedValue, 

93 ExtendedTypeSerDes, 

94 JsonSerDes, 

95 PassThroughSerDes, 

96 SerDes, 

97 SerDesPipelineError, 

98 SerDesStage, 

99 TypeCodecExtension, 

100 TypeTag, 

101 create_serdes_pipeline, 

102 deserialize, 

103 get_serdes_context, 

104 is_composable_serdes, 

105 serialize, 

106) 

107from .state import RECURSIVE_LEVEL_INPUT_FIELD, ExecutionState 

108from .task import create_eager_task 

109 

110__all__ = [ 

111 "CallableRuntimeError", 

112 "ComposableSerDes", 

113 "DurableContext", 

114 "DurableExecutionsError", 

115 "DurableServiceClient", 

116 "ErrorObject", 

117 "ExecutionError", 

118 "ExtendedTypeSerDes", 

119 "InvalidStateError", 

120 "InvocationError", 

121 "InvocationStatus", 

122 "JitterStrategy", 

123 "JsonSerDes", 

124 "LambdaContext", 

125 "OperationStatus", 

126 "OperationSubType", 

127 "OperationType", 

128 "RetryStrategy", 

129 "RetryableSerDesError", 

130 "SerDes", 

131 "SerDesContext", 

132 "SerDesError", 

133 "SerDesPipelineError", 

134 "SerDesStage", 

135 "UserlandError", 

136 "ValidationError", 

137 "create_default_sync_client", 

138 "create_serdes_pipeline", 

139 "durable_callable", 

140 "durable_execution", 

141 "get_current_context", 

142 "get_durable_context", 

143 "get_serdes_context", 

144 "is_composable_serdes", 

145]