Azure
diff --git a/‎CHANGELOG.md‎
Lines changed: 9 additions & 0 deletions b/‎CHANGELOG.md‎
Lines changed: 9 additions & 0 deletions
diff --git a/‎azure/durable_functions/models/DurableOrchestrationContext.py‎
Lines changed: 2 additions & 1 deletion b/‎azure/durable_functions/models/DurableOrchestrationContext.py‎
Lines changed: 2 additions & 1 deletion
diff --git a/‎azure/durable_functions/models/actions/CreateTimerAction.py‎
Lines changed: 42 additions & 0 deletions b/‎azure/durable_functions/models/actions/CreateTimerAction.py‎
Lines changed: 42 additions & 0 deletions
diff --git a/‎azure/durable_functions/models/actions/__init__.py‎
Lines changed: 3 additions & 1 deletion b/‎azure/durable_functions/models/actions/__init__.py‎
Lines changed: 3 additions & 1 deletion
diff --git a/‎azure/durable_functions/tasks/__init__.py‎
Lines changed: 3 additions & 1 deletion b/‎azure/durable_functions/tasks/__init__.py‎
Lines changed: 3 additions & 1 deletion
diff --git a/‎azure/durable_functions/tasks/create_timer.py‎
Lines changed: 41 additions & 0 deletions b/‎azure/durable_functions/tasks/create_timer.py‎
Lines changed: 41 additions & 0 deletions
diff --git a/‎azure/durable_functions/tasks/task_utilities.py‎
Lines changed: 24 additions & 0 deletions b/‎azure/durable_functions/tasks/task_utilities.py‎
Lines changed: 24 additions & 0 deletions
diff --git a/‎azure/durable_functions/tasks/timer_task.py‎
Lines changed: 47 additions & 0 deletions b/‎azure/durable_functions/tasks/timer_task.py‎
Lines changed: 47 additions & 0 deletions
diff --git a/‎samples/aml_monitoring/.funcignore‎
Lines changed: 5 additions & 0 deletions b/‎samples/aml_monitoring/.funcignore‎
Lines changed: 5 additions & 0 deletions
diff --git a/‎samples/aml_monitoring/.gitignore‎
Lines changed: 44 additions & 0 deletions b/‎samples/aml_monitoring/.gitignore‎
Lines changed: 44 additions & 0 deletions
@@ -2,6 +2,15 @@
 
 All notable changes to this project will be documented in this file.
 
+## 1.0.0b6
+
+- [Create timer](https://github.com/Azure/azure-functions-durable-python/issues/35) functionality available
+
+## 1.0.0b5
+
+- [Object serialization](https://github.com/Azure/azure-functions-durable-python/issues/90) made available
+- [Can set custom status](https://github.com/Azure/azure-functions-durable-python/issues/117) of orchestration
+
 ## 1.0.0b3-b4
 - Release to test CD pipeline with push to PyPI
 
 
@@ -9,7 +9,7 @@
 from ..models.Task import Task
 from ..models.TokenSource import TokenSource
 from ..tasks import call_activity_task, task_all, task_any, call_activity_with_retry_task, \
-    wait_for_external_event_task, continue_as_new, new_uuid, call_http
+    wait_for_external_event_task, continue_as_new, new_uuid, call_http, create_timer_task
 from azure.functions._durable_functions import _deserialize_custom_object
 
 
@@ -51,6 +51,7 @@ def __init__(self,
         self.continue_as_new = lambda i: continue_as_new(input_=i)
         self.task_any = lambda t: task_any(tasks=t)
         self.task_all = lambda t: task_all(tasks=t)
+        self.create_timer = lambda d: create_timer_task(state=self.histories, fire_at=d)
         self.decision_started_event: HistoryEvent = \
             [e_ for e_ in self.histories
              if e_.event_type == HistoryEventType.ORCHESTRATOR_STARTED][0]
 
@@ -0,0 +1,42 @@
+from typing import Any, Dict
+
+from .ActionType import ActionType
+from ..utils.json_utils import add_attrib, add_datetime_attrib
+import datetime
+
+
+class CreateTimerAction:
+    """Defines the structure of the Create Timer object.
+
+    Returns
+    -------
+        Information needed by durable extension to schedule the activity
+
+    Raises
+    ------
+    ValueError
+        if the event fired is not of valid datetime object
+    """
+
+    def __init__(self, fire_at: datetime, is_cancelled: bool = False):
+        self.action_type: ActionType = ActionType.CREATE_TIMER
+        self.fire_at: datetime = fire_at
+        self.is_cancelled: bool = is_cancelled
+
+        if not isinstance(self.fire_at, datetime.date):
+            raise ValueError("fireAt: Expected valid datetime object but got ", self.fire_at)
+
+    def to_json(self) -> Dict[str, Any]:
+        """
+        Convert object into a json dictionary.
+
+        Returns
+        -------
+        Dict[str, Any]
+            The instance of the class converted into a json dictionary
+        """
+        json_dict = {}
+        add_attrib(json_dict, self, 'action_type', 'actionType')
+        add_datetime_attrib(json_dict, self, 'fire_at', 'fireAt')
+        add_attrib(json_dict, self, 'is_cancelled', 'isCanceled')
+        return json_dict
@@ -5,12 +5,14 @@
 from .CallActivityWithRetryAction import CallActivityWithRetryAction
 from .WaitForExternalEventAction import WaitForExternalEventAction
 from .CallHttpAction import CallHttpAction
+from .CreateTimerAction import CreateTimerAction
 
 __all__ = [
     'Action',
     'ActionType',
     'CallActivityAction',
     'CallActivityWithRetryAction',
     'CallHttpAction',
-    'WaitForExternalEventAction'
+    'WaitForExternalEventAction',
+    'CreateTimerAction'
 ]
@@ -8,6 +8,7 @@
 from .continue_as_new import continue_as_new
 from .new_uuid import new_uuid
 from .call_http import call_http
+from .create_timer import create_timer_task
 
 __all__ = [
     'call_activity_task',
@@ -18,5 +19,6 @@
     'task_all',
     'task_any',
     'should_suspend',
-    'wait_for_external_event_task'
+    'wait_for_external_event_task',
+    'create_timer_task'
 ]
@@ -0,0 +1,41 @@
+from typing import List
+from ..models.actions.CreateTimerAction import CreateTimerAction
+from ..models.history import HistoryEvent
+from .task_utilities import find_task_timer_created, find_task_retry_timer_fired, set_processed
+import datetime
+from .timer_task import TimerTask
+
+
+def create_timer_task(state: List[HistoryEvent],
+                      fire_at: datetime) -> TimerTask:
+    """Durable Timers are used in orchestrator function to implement delays.
+
+    Parameters
+    ----------
+    state : List[HistoryEvent]
+        The list of history events to search to determine the current state of the activity
+    fire_at : datetime
+        The time interval to fire the timer trigger
+
+    Returns
+    -------
+    TimerTask
+        A Durable Timer Task that schedules the timer to wake up the activity
+    """
+    new_action = CreateTimerAction(fire_at)
+
+    timer_created = find_task_timer_created(state, fire_at)
+    timer_fired = find_task_retry_timer_fired(state, timer_created)
+
+    set_processed([timer_created, timer_fired])
+
+    if timer_fired:
+        return TimerTask(
+            is_completed=True, action=new_action,
+            timestamp=timer_fired.timestamp,
+            id_=timer_fired.event_id)
+    else:
+        return TimerTask(
+            is_completed=False, action=new_action,
+            timestamp=None,
+            id_=None)
@@ -1,5 +1,6 @@
 import json
 from ..models.history import HistoryEventType
+from ..constants import DATETIME_STRING_FORMAT
 from azure.functions._durable_functions import _deserialize_custom_object
 
 
@@ -118,6 +119,29 @@ def find_task_failed(state, scheduled_task):
     return tasks[0]
 
 
+def find_task_timer_created(state, fire_at):
+    """Locate the Timer Created Task.
+
+    Within the state passed, search for an event that has hasn't been processed,
+    is a timer created task type,
+    and has the an event id that is one higher then Scheduled Id of the provided
+    failed task provided.
+    """
+    if fire_at is None:
+        return None
+
+    tasks = []
+    for e in state:
+        if e.event_type == HistoryEventType.TIMER_CREATED and hasattr(e, "FireAt"):
+            if e.FireAt == fire_at.strftime(DATETIME_STRING_FORMAT):
+                tasks.append(e)
+
+    if len(tasks) == 0:
+        return None
+
+    return tasks[0]
+
+
 def find_task_retry_timer_created(state, failed_task):
     """Locate the Timer Created Task.
 
 
@@ -0,0 +1,47 @@
+from ..models.Task import Task
+
+
+class TimerTask(Task):
+    """Represents a pending timer.
+
+    All pending timers must be completed or canceled for an orchestration to complete.
+
+    Example: Cancel a timer
+    ```
+    timeout_task = context.df.create_timer(expiration_date)
+    if not timeout_task.is_completed():
+        timeout_task.cancel()
+    ```
+    """
+
+    def __init__(self, action, is_completed, timestamp, id_):
+        self._action = action
+        self._is_completed = is_completed
+        self._timestamp = timestamp
+        self._id = id_
+
+        super().__init__(self._is_completed, False,
+                         self._action, None, self._timestamp, self._id, None)
+
+    def is_cancelled(self) -> bool:
+        """Check of a timer is cancelled.
+
+        Returns
+        -------
+        bool
+            Returns whether a timer has been cancelled or not
+        """
+        return self._action.is_cancelled
+
+    def cancel(self):
+        """Cancel a timer.
+
+        Raises
+        ------
+        ValueError
+            Raises an error if the task is already completed and an attempt is made to cancel it
+        """
+        if not self._is_completed:
+            self._action.is_cancelled = True
+        else:
+            raise ValueError("Cannot cancel a completed task.")
@@ -0,0 +1,5 @@
+.git*
+.vscode
+local.settings.json
+test
+py36
@@ -0,0 +1,44 @@
+bin
+obj
+csx
+.vs
+edge
+Publish
+
+*.user
+*.suo
+*.cscfg
+*.Cache
+project.lock.json
+
+/packages
+/TestResults
+
+/tools/NuGet.exe
+/App_Data
+/secrets
+/data
+.secrets
+appsettings.json
+local.settings.json
+
+node_modules
+dist
+
+# Local python packages
+.python_packages/
+
+# Python Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+py36
-Original file line number
+Diff line change
@@ @@ -0,0 +1,5 @@ @@
 +.git*
 +.vscode
 +local.settings.json
 +test
 +py36