hh(SSKJr SSKJr SSKJr SSKJr SSKJ r J r Jr SSK J r Sr S r\"S S S S 9S5r\"S S S S 9SSj5r\"S S SS 9S5r\S5rg)) shared_task)Stamp) WorkBalance)*calculate_daily_balances_for_user_and_date)date timedeltadatetime)cacheschedule_catch_up_balances_lockihT)bind max_retriesdefault_retry_delaycSSKJn UR"US5R5n[X5nSXS.$![anUR US9eSnAff=f)Nr)r %Y-%m-%dok)statususer_idrexc)r strptimerr Exceptionretry)selfrdate_isor dwbrs &D:\TimeStamps\worktimeservice\tasks.pycalculate_balance_taskr! s["%   h 3 8 8 : 7 C'DD "jjSj!!"s69 AAANc[R"5nU(a&[R"US5R5nO[R R US9RS5R5nU(aUR[SS9-nOS[R R US9RS5R5nU(a URnOSUS.$UnXs::a[X5 U[SS9- nXs::aMS XR5UR5S .$![anURUS 9eSnAff=f) Nrr-daterdaysrno_datarrr)rr start_dateend_dater)rtodayr rrobjectsfilterorder_byfirstr rr isoformatrr) rrstart_date_isor+r) last_balance first_stamp current_daters r calculate_balance_tasksr5s-"  !**>:FKKMJ'..55g5FOOPWX^^`L)..1BB #mm2272CLLVTZZ\ !,!1!1J&/7CC" # 6w M I1- -L#'AUAUAWejetetevww "jjSj!!"s$C,D6/#D6!D66 EEEcx[R"5[SS9- nU[SS9- n[RR US9R S5R5nU(aUR[SS9-nOS[RR US9R S5R5nU(a URnOSUS.$[XS5nUnXr::a[X5 U[SS9- nXr::aMS XR5S .$![anURUS 9eS nAff=f) z Computes balances for a user from their last recorded balance up to yesterday, but limits the historical depth to 7 days for efficiency. rr%r#r$rr'r(r)rrr*rN)rr+r rr,r-r.r/rmaxrr0rr) rr yesterday hard_limitr2r)r3r4rs r catch_up_work_balances_for_userr<:s% "JJL9!#44 !22 #**11'1BKKGTZZ\ %**YA->>J--..w.?HHPVVXK(-- "+@@0 ! ' 6w M I1- -L'7@S@S@UVV "jjSj!!"s$CD.DD D9%D44D9cn[R"[S[5(af[R R SSS9R5nUHn[RU5 M [R"[5 g[S5 g![R"[5 f=f)z Triggers the catch-up task for all users who have stamps. Protected by a lock to ensure only one orchestrator runs at a time. truerT)flatz3Catch-up orchestrator skipped due to existing lock.N) r addLOCK_ID LOCK_EXPIRErr, values_listdistinctr<delaydeleteprint)user_idsrs r schedule_catch_up_balancesrI_s yy&+.. "}}000FOOQH#/55g>$ LL ! CD LL !s A BB4)N)celeryr stamps.modelsrmodelsrservicerr rr django.core.cacher rArBr!r5r<rIr rQs?..# +  $A1= "> " $A1=">"@ $A2>!"?!"H E ErP