diff --git a/temporalio/.DS_Store b/temporalio/.DS_Store
new file mode 100644
index 000000000..5fd5f27c1
Binary files /dev/null and b/temporalio/.DS_Store differ
diff --git a/temporalio/activity.py b/temporalio/activity.py
index c67fa0f38..5ab933b21 100644
--- a/temporalio/activity.py
+++ b/temporalio/activity.py
@@ -117,6 +117,7 @@ class Info:
     workflow_run_id: str
     workflow_type: str
     priority: temporalio.common.Priority
+    retry_policy: Optional[temporalio.common.RetryPolicy] = None
     # TODO(cretz): Consider putting identity on here for "worker_id" for logger?
 
     def _logger_details(self) -> Mapping[str, Any]:
diff --git a/temporalio/bridge/.DS_Store b/temporalio/bridge/.DS_Store
new file mode 100644
index 000000000..8d52a6e1d
Binary files /dev/null and b/temporalio/bridge/.DS_Store differ
diff --git a/temporalio/worker/_activity.py b/temporalio/worker/_activity.py
index 413dee138..0bd5fe0c3 100644
--- a/temporalio/worker/_activity.py
+++ b/temporalio/worker/_activity.py
@@ -412,6 +412,9 @@ async def _run_activity(
                 workflow_run_id=start.workflow_execution.run_id,
                 workflow_type=start.workflow_type,
                 priority=temporalio.common.Priority._from_proto(start.priority),
+                retry_policy=temporalio.common.RetryPolicy.from_proto(start.retry_policy)
+                if start.HasField("retry_policy")
+                else None,
             )
             running_activity.info = info
             input = ExecuteActivityInput(