From d09e92db22b518445e51ec1f400f4a4dc954ee58 Mon Sep 17 00:00:00 2001
From: Yaroslav Taben <yaroslav.taben@instacart.com>
Date: Tue, 22 Apr 2025 15:51:08 -0400
Subject: [PATCH] Add retry_policy to activity Info

---
 temporalio/.DS_Store           | Bin 0 -> 6148 bytes
 temporalio/activity.py         |   1 +
 temporalio/bridge/.DS_Store    | Bin 0 -> 6148 bytes
 temporalio/worker/_activity.py |   3 +++
 4 files changed, 4 insertions(+)
 create mode 100644 temporalio/.DS_Store
 create mode 100644 temporalio/bridge/.DS_Store

diff --git a/temporalio/.DS_Store b/temporalio/.DS_Store
new file mode 100644
index 0000000000000000000000000000000000000000..5fd5f27c1e220a35131af404e96aa06c96e8fa55
GIT binary patch
literal 6148
zcmeHLJx?1!5S@+B*a8X{DU6^v3DP7=;eT*gPJ|Q+gcH%>#2>OPY@c<B713QEiH;&|
zlp+xg{0I0ak*N3&c{97<U0*H|4I<HwwEOO6XJ_8MyS??9h*W*ntr1m-sEo!KETj8_
z@i@1PJu#jtP)UvseV`5vs7I|#w0C#~yaJC+0baW+SgkFZ(lOTVeEqgY{aUjVkEcR8
zxPF%(IgT5R_9$*6qC7c!y8E?qwf(o~?meQX1B*p5LRu<-<&=gFzxB62=OZ?sjjf$G
zhL4#yj_38WqfWg|elOAzwJD(?b*WE1t7_p{a=x}WZr3gzRKI<BAzC;&YzBET7LUU7
zYRWuHxIZyX=##K%TTC!`_%a(|bE)jFe!n@r<omLa$7YisW${4@c_>O?(xZ>)hhWur
z`TTk<m7EBh&ukprJ|_!#Y(Du>4j&bw81B<&=#$V9SS1ddrIR0v<2IMU#T^$Xhs`7}
z#^F)gV;=vCVb5kOuW0nWSHLUa6}VG?-wz=gV`MPZD6bB5@(BP8;1<KN?3uuj9l*$7
zsu3QT(o=zYsxqG#N>7JBG;xu^RHL3wN-86dsjSQwijwN^hZ0UI(&&4yfLFj(prB7H
zy#K$-|NeI;`7^J8SKz-=Kn0CvqmD~5du!(6c&`o7-lMT`T&hu~pflUC9Pn1m|0{@L
ZEaU@VWH8kT56u4%5E*>u6?jkuegiRI#x(!{

literal 0
HcmV?d00001

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 0000000000000000000000000000000000000000..8d52a6e1df64619a6d4a5688e4f91109cbce73f5
GIT binary patch
literal 6148
zcmeHK!AiqG5S^_>QoQ8Y<KD$X{veik7jhQ0O{vg^6s;G%<e(=(^d$5@`~X3JNKf8;
zv$NHtX~C07nSt52*_qkhybU`UA~L<pEFubtD1b7yI%rl1+gTgZ@*`|CZjJ#JbWX#`
zC`udNI`AJEki)&8jK;J_mGc`E`IOJ~X#RKu3~0$GFOsA`Df(=?|9tA+hHv|;{jy*A
zP0ylqvF7pfA*P~jn$an~rx6Wl#^2P!{_=6Pvuv;Kr}I9Z-|f2n)aJ;GpS`T}sqW+T
z`hoYMq6{bl%D|>EfSk<|@Lj5+3@8K2K$QW$A1stH_E-wKs{@TI0f21`J3*go368NI
zV~?dEED$51KnXRz#4r+$aqInJkENi5lkvre@hcl&p%}M1=C{tBOf0CaGN2698Q7A?
zkn{h+`ue{fq)*C#GO$q$n0AsTJ-m|7t&NxCTx+2xP!{$p1;0bkaj6)-oQk_pCm6Tf
W0mdFnL5x83N5IjbjWY134159j)l)kF

literal 0
HcmV?d00001

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(