Fix broken code after sdk upgrades

Author: longquanzheng

moneytransfer/main.py

@@ -17,7 +17,7 @@
 flask_app = Flask(__name__)
 
 
-# http://localhost:8802/moneytransfer/start
+# http://localhost:8802/moneytransfer/start?fromAccount=long&toAccount=github&amount=10&notes=testnotest
 @flask_app.route("/moneytransfer/start")
 def money_transfer_start():
     from_account = request.args["fromAccount"]

moneytransfer/money_transfer_workflow.py

@@ -54,7 +54,7 @@ def execute(
 
     def get_state_options(self) -> WorkflowStateOptions:
         return WorkflowStateOptions(
-            execute_failure_handling_state=CompensateState,
+            proceed_to_state_when_execute_retry_exhausted=CompensateState,
             execute_api_retry_policy=RetryPolicy(
                 maximum_attempts_duration_seconds=3600,
                 # replace with this to try a shorter retry
@@ -78,7 +78,7 @@ def execute(
 
     def get_state_options(self) -> WorkflowStateOptions:
         return WorkflowStateOptions(
-            execute_failure_handling_state=CompensateState,
+            proceed_to_state_when_execute_retry_exhausted=CompensateState,
             execute_api_retry_policy=RetryPolicy(
                 maximum_attempts_duration_seconds=3600,
             )
@@ -100,7 +100,7 @@ def execute(
 
     def get_state_options(self) -> WorkflowStateOptions:
         return WorkflowStateOptions(
-            execute_failure_handling_state=CompensateState,
+            proceed_to_state_when_execute_retry_exhausted=CompensateState,
             execute_api_retry_policy=RetryPolicy(
                 maximum_attempts_duration_seconds=3600,
             )
@@ -123,7 +123,7 @@ def execute(
 
     def get_state_options(self) -> WorkflowStateOptions:
         return WorkflowStateOptions(
-            execute_failure_handling_state=CompensateState,
+            proceed_to_state_when_execute_retry_exhausted=CompensateState,
             execute_api_retry_policy=RetryPolicy(
                 maximum_attempts_duration_seconds=3600,
             )

signup/signup_workflow.py

@@ -1,5 +1,4 @@
 from dataclasses import dataclass
-from datetime import timedelta
 
 from iwf.command_request import CommandRequest, InternalChannelCommand, TimerCommand
 from iwf.command_results import CommandResults
@@ -54,9 +53,7 @@ def wait_until(
         communication: Communication,
     ) -> CommandRequest:
         return CommandRequest.for_any_command_completed(
-            TimerCommand.timer_command_by_duration(
-                timedelta(seconds=10)
-            ),  # use 10 seconds for demo
+            TimerCommand.by_seconds(10),  # use 10 seconds for demo
             InternalChannelCommand.by_name(verify_channel),
         )
 
@@ -93,7 +90,7 @@ def get_persistence_schema(self) -> PersistenceSchema:
 
     def get_communication_schema(self) -> CommunicationSchema:
         return CommunicationSchema.create(
-            CommunicationMethod.internal_channel_def(verify_channel, None)
+            CommunicationMethod.internal_channel_def(verify_channel, type(None))
         )
 
     @rpc(