From 73a08dffdbbcfdccb69153d5fad2e463238c2f5f Mon Sep 17 00:00:00 2001
From: mohammedalfakih-dev <mohammedalfakih23@gmail.com>
Date: Wed, 10 Jun 2026 00:52:47 +0200
Subject: [PATCH] Complete week 6 Azure deployment pipeline

---
 AI_ASSIST.md               |  19 +++-
 Dockerfile                 |   8 +-
 README.md                  |  52 +++++++----
 docs/execution_history.png | Bin 0 -> 21240 bytes
 docs/execution_history.txt |   3 +
 requirements.txt           |   2 +
 src/pipeline.py            | 181 +++++++++++++++++++++++++++++--------
 7 files changed, 201 insertions(+), 64 deletions(-)
 create mode 100644 docs/execution_history.png
 create mode 100644 docs/execution_history.txt

diff --git a/AI_ASSIST.md b/AI_ASSIST.md
index 9b31b94..28a225f 100644
--- a/AI_ASSIST.md
+++ b/AI_ASSIST.md
@@ -8,18 +8,31 @@
 
 <!-- Paste the exact prompt you gave an LLM (ChatGPT, Claude, Copilot, etc.). -->
 
-TODO: paste your prompt here.
+help me complete the Azure deployment for my weather pipeline. I am already done doing the pipeline to upload raw JSON to Azure Blob Storage and insert weather rows into Azure Postgres and both the local Python run and Docker run were working after pushing my Docker image to Azure Container Registry I tried to create and verify an Azure Container App Job but Azure CLI kept failing with this error:
+
+ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None)
+
+I
 
 ## The code or suggestion it returned
 
 <!-- Paste the suggestion verbatim — code, shell commands, or both. -->
 
 ```text
-TODO: paste the AI output here.
+ChatGPT explained that the error was not caused by my Python pipeline or Docker image. The pipeline had already worked locally, Docker had worked locally, Blob Storage upload had worked, Postgres insert had worked, and the image tag was visible in ACR. The problem was with Azure CLI on my local Windows/Git Bash environment while running az containerapp commands.
+
+It suggested checking the job list first:
+
+az containerapp job list \
+  --resource-group rg-hyf-data \
+  --output table
+
+When the same Azure CLI connection reset error continued, ChatGPT suggested using Azure Cloud Shell instead of my local terminal, because Cloud Shell runs inside Azure and avoids the local network/CLI connection problem.
 ```
 
 ## What I changed after reviewing it
 
 <!-- Describe what you accepted, rejected, or modified, and why. -->
 
-TODO: describe your review here.
+accepted the suggestion to use Azure Cloud Shell because the problem was not in the pipeline code. Before this, I had already verified that the Python pipeline could upload the blob and write rows to Postgres locally, and I had verified that the Docker image ran correctly.
+In Cloud Shell, I created the Container App Job using my own image
diff --git a/Dockerfile b/Dockerfile
index ee3c978..b43c7cd 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -12,10 +12,10 @@ FROM python:3.11-slim
 WORKDIR /app
 
 # TODO Task 4: copy requirements.txt (must appear before any COPY src command)
-
+COPY requirements.txt .
 # TODO Task 4: install dependencies with pip
-
+RUN pip install --no-cache-dir -r requirements.txt
 # TODO Task 4: copy the src/ folder
-
+COPY src/ src/
 # TODO Task 4: set the CMD to run the pipeline (python -m src.pipeline)
-CMD ["python", "-c", "raise SystemExit('Dockerfile not finished: Task 4 still pending')"]
+CMD ["python", "-m", "src.pipeline"]
diff --git a/README.md b/README.md
index fa94600..39cc229 100644
--- a/README.md
+++ b/README.md
@@ -30,14 +30,14 @@ data-assignment-week-6/
 
 ## Where to start
 
-| Step | File | Task in the chapter |
-|---|---|---|
-| 1 | `requirements.txt` | Pin `azure-storage-blob` and `psycopg2-binary` |
-| 2 | `src/pipeline.py` | Implement `get_config`, `upload_raw_to_blob`, `write_to_postgres` (Tasks 1-3) |
-| 3 | `Dockerfile` | Finish the cache-friendly image (Task 4) |
-| 4 | Azure CLI | Deploy as a Container App Job (Task 4-5) |
-| 5 | `docs/execution_history.png` | Add the Execution-history portal screenshot (Task 5) |
-| 6 | `AI_ASSIST.md` | Fill in your AI prompt + review (Task 7) |
+| Step | File                         | Task in the chapter                                                           |
+| ---- | ---------------------------- | ----------------------------------------------------------------------------- |
+| 1    | `requirements.txt`           | Pin `azure-storage-blob` and `psycopg2-binary`                                |
+| 2    | `src/pipeline.py`            | Implement `get_config`, `upload_raw_to_blob`, `write_to_postgres` (Tasks 1-3) |
+| 3    | `Dockerfile`                 | Finish the cache-friendly image (Task 4)                                      |
+| 4    | Azure CLI                    | Deploy as a Container App Job (Task 4-5)                                      |
+| 5    | `docs/execution_history.png` | Add the Execution-history portal screenshot (Task 5)                          |
+| 6    | `AI_ASSIST.md`               | Fill in your AI prompt + review (Task 7)                                      |
 
 ## Open in Codespaces
 
@@ -82,17 +82,17 @@ The grader reports a score out of 100. The passing threshold is 60.
 
 ## Scoring ladder
 
-| Points | What the grader checks |
-|---|---|
-| 10 | Required files exist (Dockerfile, requirements.txt, src/pipeline.py, AI_ASSIST.md, docs/) |
-| 10 | requirements.txt pins `azure-storage-blob` and `psycopg2-binary` |
-| 10 | Dockerfile copies requirements before src (cache-friendly layer order) |
-| 15 | Pipeline reads both env vars, wraps the Postgres connection so it is closed cleanly, and silences the Azure SDK logger |
-| 15 | Pipeline uses an idempotent upsert (`ON CONFLICT ... DO UPDATE`) |
-| 10 | Connection string uses the Azure-required SSL flag and the blob SDK client class |
-| 10 | AI_ASSIST.md has all three sections and is filled in (>=1800 chars, no `TODO:`) |
-| 10 | README has a `## Verification` heading and references an image in `docs/` |
-| 10 | `docs/execution_history.png` exists and is non-trivial (real screenshot) |
+| Points | What the grader checks                                                                                                 |
+| ------ | ---------------------------------------------------------------------------------------------------------------------- |
+| 10     | Required files exist (Dockerfile, requirements.txt, src/pipeline.py, AI_ASSIST.md, docs/)                              |
+| 10     | requirements.txt pins `azure-storage-blob` and `psycopg2-binary`                                                       |
+| 10     | Dockerfile copies requirements before src (cache-friendly layer order)                                                 |
+| 15     | Pipeline reads both env vars, wraps the Postgres connection so it is closed cleanly, and silences the Azure SDK logger |
+| 15     | Pipeline uses an idempotent upsert (`ON CONFLICT ... DO UPDATE`)                                                       |
+| 10     | Connection string uses the Azure-required SSL flag and the blob SDK client class                                       |
+| 10     | AI_ASSIST.md has all three sections and is filled in (>=1800 chars, no `TODO:`)                                        |
+| 10     | README has a `## Verification` heading and references an image in `docs/`                                              |
+| 10     | `docs/execution_history.png` exists and is non-trivial (real screenshot)                                               |
 
 ## Submitting
 
@@ -108,3 +108,17 @@ repo (`Data Track/Week 6/week_6__8_assignment.md`). The auto-grader checks
 code shape, not live Azure deployment, because the GitHub Actions runner has
 no Azure credentials. To rebuild from a fresh scaffold, follow
 `.agents/workflows/build_assignment_repo.md` in the curriculum repo.
+
+## Verification
+
+The Container App Job ran successfully.
+
+Execution history screenshot:
+
+![Execution history](docs/execution_history.png)
+
+CLI output is saved in:
+
+```text
+docs/execution_history.txt
+```
diff --git a/docs/execution_history.png b/docs/execution_history.png
new file mode 100644
index 0000000000000000000000000000000000000000..fdb529f8ad2669cb565869f753d8b47c3d6d2655
GIT binary patch
literal 21240
zcmeFZcUV(d*FMbXpd$#3(xi_{5fB(!q{l|@y#z!Fy$YeX*bwPT?*ZvuN(dbl>5xbX
zp$4geP$D%D2>gQc%)I0K{QrI5^<BSnUF2{M`@lYHuX3-o?oEWAjw&4uI}H^T6`i`;
zLjx)*S|H_n_-_{|pZ&%;e3a8K5ChfwRFz21Rm#P$4)?V0QBhUL(H=jcrd(fos%8$M
zqN49O`}(EZqu7>;${<Gl;XNb&M;kLxS59IG?v#~F{t?_n`Ox{D7dR|-{Z0LX*Xp(3
z!#rq*iK=R>AJnPUlidTabKJ@CzI0cR9C}kw8R_*hS!2^+_?hAGQ!Dkx3;AC6l4GCW
zM2mgri*dPkL9eAulWAC;Ng_7EYQmHtq*J@rvxPhAK1olT;Ujj34~y;vQ;FS`mpqzC
zLk%F2&a=l_FL`fL=KIr8?0Lsu;HNv3i@PH457_?K&AV1P|Bv0ftL?J3ZsGt+@RRu0
zEE?$bk1tcMa{$tGx2}oPpis_AEu~*q9ucnoYt%Qn2V0VqYrTTaxda-dh+zDiTi3oL
zE5xMXBH{EURkAxD1x}wcvipktLRHKN-##=DUi;<m=b!aeSRHfzCS((>B^U9v*zZ#K
zvls7nYu@D?kbk3$*~<w!$hS|v5y^LTV(k$)TI)uknXNi4<Q~`RzEXdM!&AKws|x4+
z0Nf}{qux$xaRnh!yKEZmZ=jA@Xn2q8rg~OpBN<{c)))BqAEe6ha$yAq9UPO>*Y|YJ
zv<a_kNGN8pQK<#L#5=i}<e?0ymt2g%kTSU@(&+3$c39b>=8+VDN1OSsK#H`_?lYu+
z$}d!|*OY|+c?-QLc3w8Zm-4%M?@E;H2vQ<~js8ZU{g7U9zMDCZZH0V5_?0@6-)7OD
zXOF<02*vkz!WU7aPx<mJ=);-mtAs?=w@Vt~#v&pW&Tj6b+Yet(GBjH}Wus%`+SW8M
z8X?QW+hfIE2~Q+%&Ux;^1B)~&6fcgVZ>Xz>73nyMqZ>v0M=tJ-niGtuK1w6hfx<3!
zivPT^9+#oi^PGs(#D}+&PcZRp9>O2W&+(_4%UqRu-g5Zr_xrzHe>JM2!g6($))agL
z(h;!JKj?UCD*e)hZ5+nX)jevko-)F6#&rzUXJO88HvGpke|;DPxPLdf&&p_>iMBC_
zw?IQ}dgOybg7%%i_2k>LBr`?uCH|?xpYTxYT>)DbCw^B+QzNbq9IelL?JX}IsyrVC
z)4MHIi7g!UI-j5!SuhnXLM`2bnTa(t#J$x)R@_Q{TGicmUoY>uBDRwvy$?>D`li0u
z`acwsVA})MsN(xb7xM(Rdj|38=sQc<DVh&g`^^zTl?jIDXjF##!&M-LsxN7jIXC!h
zEYdgzAITS)VUtT`>kITar%ZpF<)HeQJh*M{<e_-(liE;#P8#a{Uh)*<HRGpGl&c?p
zCQnAZvZ;QPY_Br95%NDu&#TVI3KW*DFx)BO$N>1#Ie#&hs%{%9QO=SZs>+Tvk-kGp
zJiMeGzvyBFaf!Piu$*L8oAasY`QwLRMUhq9(dY^=hp~IA&M#QKhy+5XKB}pP>k4$K
zSfY?CTntV=q4!@}i8y;#zNyj|;R=zHVjk<WrKZMGR<!v1;I>`mFA3_(VgdHncD|Jf
zT>F=uy!diU9)xV)k)Pa=E-hGlTi9`rE-^sF8hSu^20gI|OTvtQ*Lv7*7(R*_df(-$
zT67rf?CNS#1|*uFnZREM;`Q$DU&E+hL~8Aom>YOES<CD02};bs0u|6jS#gR4OS4Zs
zi6jHsGAJ%I%X5H>u0RE&-en4JX(?a&UOG>C+vN5#O)il}n0K;(oHyzdVG-yTU_LZv
z0_QcAmS;B6gu*OB;*&dQ5C==dPUh@%lNuL2uEBVwv542cT>bUD8(efwCvSm!56r!c
zcMQSlsTL+J)y5&@mw3XC1Ju$Y3qO)o>GmtdUy?b-EN!%`N@(wg2?UOYepe>kcUc+x
z?hmuzGPDSyFD_Fq*)OD6#@?Nm+@2yjoFl6{n<Z#Vfg+j84pUb6_;_yYuHk%tZF-iq
zaZTfckl3~9X?V+w+g6`z1{2!*RA<94^xiF-$F>U1C-M1R^mO}0RkIynXGh?A>S`D9
z0@Vk*+F+AOP~6==-<OO+11k>G>ah;9*eyO0?w)de%d$CT5z#_~YK-$1qPU>ISR@^j
zgF7AjThvr<!IAvGOI=C0dg($muOz!hKL3~Hfu{+O!)KS4SpdK2f@YroQtPMt9HUkQ
zQLr5r!6`ze64RbUi;GL%nYQIkd!CjG4*dK|g~+a6=oT!fC}Q*Cm+rN7t~+V6{PmAx
z*9WcR3X%E=6Au%9OB<>`w)<hTY9U2_UVISa)HW&3JI|#njWL>=foKTX{C;Vpj!vg1
zSN6N#(h{C4RxYJqu&=@FhfS#$q`Pf(X@Fu0y!=w>z}YKpcYeSBrq#6))n_SW6?b<N
z*g6)Bo!pQI)}{>jKS#0tFXvDbdgdIeaNoZKJ4>Z^iE_zcm$R%!CnSsZvQk<NA&(Sf
z3J(Vy<p)LZ-v>}?uXR^*iwuY$ZT^Htwjn1jU?%$nt_9N6@pbED*Ab{LqO-fIiM_YO
zYZbWlAy!w_kRdp9kMmXt2gNby@nl2Sbz;IGnCKX;i&F4RJzl2Km5=DwlUkpwOlIrR
zh)Q4bA)8-biVkeph9rT=_r-Hk>_0~?gH*enzN)7QA;GqcMOY4k|MBY|NqwTBW0DLm
z&a!)`v9<*of1K%hU9xHGNXz?lrAI3OjJilH*YM<>bo%0MSR0+Qm%d@QLD=tM3c%K4
zEi1LC_HId5%9>|<n%ft_!_17NK$s=N+IHP=oiMwrS41*7O^Dn?NM(#cWx`1OlbF5r
zk?I$nMh<o9jXg8FXT}R~?L+msI0F#bF;;R)vWsa9f2+_lgGB4&+p7n=@8jb~r}G}%
z)W%NmIZ>jxA3{DxiD1Azq^!+aZe%t#pAyN+rxriiG@8z4<=|snmW}b{<JOIF7wN_I
zD_lC8-eB6xqq^G8s!!EUVUQ%N_$qU*m*8}(SSR=Vk;6nf(;*+PF1b84Zg&s82M=Dd
zvrifqOZks{3p!6_R=cVsTvbvlC(f)xhNTBPufpD{KV+hbb!i~tV+-m2o~<5ANGP<;
zd;OJxpZ|VI9#pFpOC7nQAW@>noBQeqvhW?t`ZU^Fa7V?Zc6b4yUhy)0zolOO<?58>
zc`B;MBhB8AiWmr{M@SLp4cUCdowA7+CMEh-syOCL^bOfIQ_`(EuQ@2o`3DayX)F^s
zR(VqWwDL4~aGS{Wb==!oYNH@6fgNA&n)A=%K3h{(?nDjm$ceXRk{mSS=o6o&Acyqs
z?+B2VJoZaOFDy`oe)PdD)#|RIc$y5SKu6M7kV!t$L@tbN33SVpzcS$$s=ZgJKD;8d
z!RqYC0Ip=npKgcg=t;@qh(lu$?d0z;x4%U|g(;zlf)(ss?3Us%b$$i=bfrR?e~{ua
zxVDR+*&3D3zOH&!C(FAc2nZW(5X?zmA+4>VIRCpD)`eC3sIcw24COb`1RO@w*Lz^h
zWFXWN?<+q&bI8S`zxYT@pD9bhTy2e<7;I>cyfN8WaIb>vrJS5}6?*#VSLY4b*FF{F
z1d1sCIz}5KDRXg<5^ok#-}c#EJ$OVoj&|q5_f7{%RUYPX1s;5NYV|*fcW9*Z9TQL2
z(JTY(+m}<G9luPEDkAvSTz6iSV{;Gopn6tg356vo9gbZKZK@uUw+j)2;_BLV#~(C7
zf?kqzMI26lD=Ki&+wbrFNAh@U<}<;E7uKaF=9}#C5VnyzJ7op3I|Sn}n9%llboMg~
zp@Zke-qr>(#$_VXzN;VK!MjS&(t~{L@_N{My2(PCM1hKQ@_r(Fla6nhD+s{Yc8BV&
zEPkW5re^Q$eDCy*h1{e9#PGHK4R+Tp9T8L-5T<r&osqw6f2g?g&rI~}wrWMWM#f!@
z;z!5PMX@h#&Xx<Mx4Jn*9d{gdp3hQ!VL_u?Qq{-vW(;yXY7@B236qNzbM|tK^ShGL
z+M0z`r_8C?FQ^$kl?>I!!v&ri2#_R<^*zHJQ2xn1Y1T-ie$uFqqe1K19cx2OuTGL%
z|MF)__`tMkADf#`1gbf746VNzs8CczucZMMSce|!vY|(nrRa8xrFTwU%F5D-0~h~V
zGAgQPqkr`J3)ufVLK9gJu9Uf1YR;YSn|@^!&y;0yiX`{lR#Zs&YG%5elF^Xt;2_=3
zo>DbYRaqH(E^p_R^w`(Rj#bsX>v<1Oj(yL6dQ(VB-$}+es`2mrs!b#$Lg1<oE^%$+
zO6wAa>_kLGon=Ej*1A~QEkGdj<nS#RZjUmZ50~<*m=k&%-uL%gSXm(-(F%nqt`LvV
zlbOx-(K-yyxRa5I?tm7|mtJELBvN?Y(KOP<b3RoEhSDzCmy_kAfMSi1lBj)rm9_A6
z^8Fgj7IkGmEuMSKAGVeeHaedBDYQK}zD}+xV!{ryzO?!>5buhgrDz+KCSb;);6d10
zZsAP}GsSmD9jE?gBO_6fB#Tk>NZ#0P;FkqYX#jxb*tPc<2m&jVqL+-7^I}8yq|4xW
z54b7@OHc}Y%t}MK`{1?U@pFHR*0M-z=+_tgHU>97-90(>evPwPEvTW*cm_#p&Erpe
zDmI^FmM*m*nPy6xrr*7z`e3y;n<Bf<{ldgw887>fAxbdORR{?-?8YBIu<;&j9d09d
z)m~60b5`Z~Iu~6Uyh?)BGQ%VwD^ug6tyq+ZRl7-@2zC4#emGgoV>bVl3T+GbEXQxx
z^P3WVlq$nf8nkQGn>$zS?YurpRqRd7A3*Ejd;`Oacd=`XKL^>jMrSeBbiSn8T)CAo
zs|{kdaS|G%9nP#Rr!uV0&uo>AE;(;C>4gHP`_b3b>WeB?z1#pT@^Fsq&X>+3_ueIH
zb-~%Q(W6864$0A2ij{p>9mpOoSq%^oRb`IrUTWk_jQ8v`?MTm(E4>Ge+MGB|ba?)`
z4botBaxx%Y=;wX~?wz%+H&pKmpsdhS#VHEjWUf#p1z26waSD~LoF0jfd|f0xM!;mn
zWsUJ+Bo&g2q!pWsmmDp(T3B_2*sRg>yJn@jJRmUBKi=}$n&pEg8uq`}=kK#~deS@C
zKj!<NyN~n!%2WRybau`W)%%gV{@;85mcakt<szjffsF{e935SjHzbc1X_LtX7oma#
z9EM(VxHbIO2dJV>U)a@^_NO1IxYbmP)Xk}I{3AEC<eI?a7guU4)&A7`)>x-6Q+JP}
zZtfw6``M_!KK6!GD!z2pf4$)L^)=&veqF`P-}lPV7k)~a@2ed)ega+k2ORzVm*B<M
zt*HO&u5`?QYy2p6<bPSg|Gh^=_5Y>}p34o5O;jN3`3bgEn5aU4kFQ_k$lpu*<NR#R
ze1-{l@x>K3u&vg^PtW{B0mF_x`A16m`UEXuO1(m&O8<{sp-1o%!v_KmbxaY0bFPx_
z^lq~ZeO5yd+0d7MWma!j`7-u=QYz>1ms<+JvcvDC_w#~UH5W?|#QrWGaIx~9Z{{Pz
z=Lr_(bS|O3kLJ*PF~mUD4@JKF{TD(3mOdFyAj(wq7@U`ad@IWTK^Ehd_`(CWTT@v5
zFcX}#_;}vfvdUrRPOuUsl$I61hh*UZF1h@+<$?3C<BK|u<E_6w)%Ib489jAZfA<A0
znmp4I%ZWGDT;^SNL4O;%nSEBm{h#9->F$=K^G7x=0zqFl?j{AZ6GcsupS>8N)WDc%
z`SUEYvxdKXdBxAqFD2bv+__X7uZ|jV)>jb3ICm{X%JH1Xn4!MqkeV#e>m=Iq<4keQ
zx+cB;J`O#k4_9Dx#*WS-AN^0Ve!W`FETYA&Pvj;rW;(lqzSRrl41IfHVsojxP5agr
z^WlNs>pp-0nBI8y$Kn^cZz%VRu@R{z%R0`*i7K}%RJ*b_pTt~bt-Bf}IA<vU_LjcD
zQPl+G#D{`}6rhVLeYb(sN1a{b_IY$1l+oy;dW{lrkSJmNPfCqQn3g6s`NY%?69|%U
zEf0?YxPGYS222(+&vXb#*D~qfe%Irs85m^qj!$HO+ULu5OwvE%c?M4nRQuzaxZoAW
z%Zn%hj+7z2rZw%JXqMFW>z97jwvWsB>UeVOGb~l}_-YzX^@V+oAT*6G0^EA@464vb
zO0cTC>Du&a(Mv525(}|dG0ft%n`7})&?PR9Gi?}I=K@Fym(*I=*mYe-Fq?H5I0v>H
z9Zu*ur3ZFv-#W@QcxY3QzXJha96@j7vu;B8m$3<lHnjG(9w(42w(Q=`!5dfkrLY-9
zg{igcy;45h;-3oO4C9np?YI_Bp7hvCx@t<};-+yfhb?5Ag=@7#uVcn7;+%<YdzVtz
zRW~hcAU+>NO2*9?INZkH#O!?-QW427@f*EeepINrl^xUr*RBXgRVMBIg`NH`F7^~^
zVqc|eX|saewk;EQN=t9kaAfxzrST4YRtpvHeQozL64tNX+G<_dE3Q%=Hjf)jO2>*B
zhXRZeu?hBkJLz4iX15%>!p|2rH&6ZgT6G}5mi^WhiM%zYVmpXPeOSY=Y+K@#UsvjQ
z--}DxoOc!$1hk(%;UlUVbzQ5Ka0;ZYyWV@bp_G-8|0+#-!oq@muvgdZ#>h^JEQXVb
z!Jso)(8<IKgQLYSF@i3og{7%WDk)_TKJ`0+xD}kq#n4qV2^Y6HH|;AYnc^n(<bJ~8
zPV2uUR7$K!%8!CEUSc%2_){`1BtXJ(Ie8d*kgC5kW#gdeTKD88V5~!hL;787-X`#y
z+QWh2&(UcE*&aIS-=<$&s`#RH<K7meqQIoh0n-=wubM0cAli=bdED17ER3oK1XT7i
z7#p*MEsX{AMtgkwtt24#pz*zB0yx@?wiA^hEZu5ddhB`&*lIs)ZY$G-_$VQfwUF!j
z&cbF+4SW2e5kGZ*dsynNkV3Rb>O15yFwq&W=;Za1USQz!yK`<bM6gY7G;tXrxyX4a
zS^YTHpP=#tthgwmr<q#t?aD}N(MK;1HV$&`V2uce-^r~b2<9&vs;=fXCV+xg*F}OY
z)g-iA6JqBNZyYt5)OU6Tjyra!{4gVD-kY?IeYl?Kr`TYFsgfkZ1iXg(Zw>jY5Iy1D
zoAFkA`C_Ej72J0%d#Q?75n)~09;Ay+&wC5jE5gB=_as}oio>%W2n-GweBrgsyV$8^
z>(mv^z{ImvtS4@Qd#BDADZ{SuWuR}m;ZnIVXSG8Wn~a1LrFyN!oBTAcIO$Pb!h@_s
zRP87aVDfum38W`86C^IK3#+{S>!9OfUF>$)@Tjb<4l<wgW$2CimmB=aTxq2}6rt}r
z4H=m;nQX<mpxreEJ5g!xW3*~>^+#4o)j?UH$0=WV#;{^6hG_9+*SvCYD@JQsh(Uv$
zTH#L4<99F8G~(s|(00uKcznZ?yZa{fa>^`EtWj`zT>A7_;>~u)?tM>-0H_QW5=%6F
zEaiCris~${jlG?_R8V$3ceiIv{c+oErYRVLR#;rsnpev<w~lNhZ5#}+Mcvz^7mpZ^
zG*8Wtq}9BVpyrRfhs1!`Q7)3KxJG_k6-`-{zVYPJDz4j^FJ0^OR}_2)YY`(mZ0pFc
zTJHYHhtJ=O5gk;jQP*%=PX>nlpA)T<DAo{dUlta{I_d81y4PJeo=m3zO|&|`E#IA*
z1W;g0(~NtXX(le&!MC|4gvrB)fOwhR`sHNjZz+gKz28)E)13OK7HBkkMN;oGPyFPW
zuVB(>r1)EkF605czAVyz8b<1d8LUj!==I4WD)we1m^h`+yLFOg9&sc=iQ~@zk*?ic
zAt+>A%>QyEzX?hPFxK=kPhIwRpGvQh!rJc#x+}Uyi${dLYpEX{b?LGqYKq)$|6Ph1
z!(e|tEB5`Hb2siu>gCYk02KoIIluR+Kq(5D_Nd#@GmLMbZ&44slgXBDX;Bmt{TXOv
zJW`}=sG@I{Yh-b3xmRCqdQ8#iM}5o{OE!%MjgiEt3ZtOtl1Omt;9;mm6=AYV+jn(5
znr$0dC3RkM;>DL?S`N<cd%TY4vJaE?Rr!;6);NrgEtfnktf2mpFyiI3-Xv)Ykb{+w
zPKkWMUF#+<X`lz=b;+hK9-NtO7>q6{`(--kQT{jCnRk}$NeAJKcCMOe3_T0-9z|KR
zyYV-W!~#E{EKu@BLLuhJQZ=*N;E{ZRZ7YtbV;@&!_S^<lb`?afR<F0aiQ;K2#2hNz
z5>T$sD^Hwwy~aLx4ZIO6;!+VF76Q7(0T*cm=iS}fx!@Mnf;qRw1^(fls15c*DaK5R
zc4;z|M~t+~6t6LCfZsC0H@eA~efF7=Bb&Q%phJisFe(L@26)5&GT`gXydL)fX*{s2
znwlk`O@5Psf!@cPCZ9EPcSTCT{89nKw--zO74nX#E%Vsf7$r3!_aI)u)6uZY>0wFJ
zE0%?itFxMK{V{)yS*l(N%-`KT*!%bvD3RiqtJ6LMk+ulIdYk*SCAe5t^SA;}Vvinx
zL~*KV>s&s^YDs3|5P@**oaQO-i?0V8ihw5kK|7@T@kMWhp4`xc@cT=k1q5C~?0aR;
zxxAyqpw*H0f_b-GAM=s}V+ZUAS6XeB6?VMX05jS3rPyS6BrGFv(0@~Dn!j4YyzZHV
zM+QIFQDD}|+fHIs%(zTfsoYo=^>1rT3f{O)U5^`B-_i&$myP84!yVc#@!@m_m?@fP
z)hM*wFJtaK0rBdRcHpc-+F~51<C;uG8<3MaU6|JX)7C4SHJiPIp8TMOyY0+)9GvDp
zU~>mhUGp}Opo3&Hbvx*r3{x~Q>~eU(UkTB(=^W7J7C%2Ta~20LbF$q@fC$HitSMcT
zjY4iCSFzEHG^t}&CQEK-S_3%Knw|{ni=NDd0Vlt2^xWT{t{qdFWxVE>Whx}}2gpTH
zA<QnJl{y<LZBqgS^w+yC9_Edn`&3hd6gM&Ga|Qb&51-hqyP+)Bo;;al=~Howf>`5P
zc>s<eBbDk>TPI3b)BnScz{;`qBrhht_d~DGlh3cZXlI!1$%%mqNnY+8*`8J_=?`st
z2dH)J+q(zChVxjfJZJPNDg-5d80nHe&35xt{J9BvUq}o4$~Ci{gM(2L(or%MN-yKi
z=gNu5L&lUZo>Z4&^z|HXNZLE<p15qVrS~%b!rY)(Ui<71KFabTD%{wg)?LXEKTlm>
zBLC;(eHMSRmRwdI)?Y=iZiwRX-`dt;WbbdhkTrO`I9P}r@)l22k3p`Aki1zQ@g)!V
zd(2HWEsr&RXD~)n{C%P&Q$6xluS?%-b}7OxX5Im_QnD1w3G#yG+pLidd|WxfEU|l6
zx<xvo;>_?Zd*08_C6pT6`{l8rd%m=3Zf@Ag+Zgc7I|CYKn$A8?=K>&2rs~z}kYPxa
z1E#5bM1bR+0V$wE$s^7`(rW*5M&o)n#a=EiwIg5W4?uEV4sVci;mCWj3>#lQziYuU
z2UYl_?A>n1)*C@L9xrg(=Ea=rAN9{9geUcGzTdfj^AKfhSR{MZvNub!cI@Oq=6!P)
zMc%Y^QQd*GxpSy?_G&awhCK-I{aC*bcdyZ$a7~zRseTAB&*mmYiS>z)5KCT)cSs5W
z{lQT!f<&#oLc9q&kLaA)Cv~U(fO@%!&DMW~a=}U$O|X{hlj&b0Ep?eSOS(q_aRA~;
zbXwTE`Ofi~8R`?g2^9`NTM)(LtF$?Q{&%bSZC}Ej>l_Z%F%WMx97A9wsL>ww?YO#6
z|Mppv>m0DycD~83x#&aJUOK;x{p)FErxNdsX%9%!NwLIZFZjbvfa@*=ne(RQu50j9
zK;#@xDlf&U|DJ<=kFvbySoyY8uk<vx)E~y8-K+eBI+8`xWWK4P23gM}7+P8SePU#D
zlKid@9n@aV#X)&FuvG`7k*Cp=e@EpwSs|oFDjV2dDidp{JLFogHUwH+GULJRo2|yh
z*C4Amdji8~I&BtY;3GWQJ8G_<qM44%y+l*mMLDwejsn0+9xu;_9ian+55G{5&M}>O
z8t(J7Y_S=vz+jhikxll*)?u#gt?gv23{sM>93(qsK!(4JfxL|YY$GZPM;32yqr^1&
znPE5{>nv5yn-C6gw0i2peb19^7yGQer!fO;Y2vD{yD9j#^NUR-^Pdq92g(Psq#n3%
zcB8-OKwaOvO?=$xCc!S++0TH>Um1<75LPnHBRaKQ?Yg4NhgA6-vi3gIctqu=yG>-Y
z-Mr`Lhq!b(F15GO($lrNxzlyAKGC9FNb}63Z3G?Ke?a|F3(Hx%81XJ%EnX(6yz>Pi
z^(lc06(R1BlU(ObhPFP<J-6|LP0AA%huLo6|1#)7Iw5tVk#2?{0Sygj&-J(2L>*tb
zVS#qBJ=Eg7AlFH(-}6iYCv40{f}8_?psKKA7*7+ow>szWXdn63+hoXpd3MnGQUfk|
z`LBju=}KI=^W<;E-Lt7AhqFGNXaH+ZU}&KJ&~7{ESTR=iCVo|okh;>spDlz{+0$4Z
z(a0J)$)a<1eClvJGmU2~)!~uohEUzbF_V+}%YzTSZ|(5ELE`UXLbI?vo4yk(#C{8k
zZ3AL`)OEF;lxizPtk~CmP|5kZpG2jLPPwubH`72Bk`{yImSFI{5AW(-Qx`l>8~vWV
zZlK7ZhFgHa(9+IoL^3IlcZp{$scctf=GlqbYw59C-ENvt6WM*R$Yc&`ima?-hAZmm
z<Gj(fyz6Oc7+WkHw3&q|k;ESI$w2jrytoQJ9omJxSYW63E^BTEJ)gUhby?JrFIn&4
zVajk-{d1vK-w&SjHA5;PY%)GZR;z|u-utiU0|B3AGqYFg{LDTTyjs@XEs@>{wagkD
zs$}8n3H?3Ep>^-A#b~PRL3)t4&H6Kv9OWV_b^eTP;G)O4Q$`cB=`&dS>4zqjH14Q+
zuJM4^%Iacp48VMOga>9{o@cC@l@^Lk1h@WBq~c(ZinO?V*@SmtS8Qo}nX;1lRwpBV
z)xZ3kUwF)Pveyq4VlqVj2U$pmPa%q-Hu^&Yg4#;bM@QZ(MrQn1hCcT`@gaBuyPH1d
zG)b`XP+G>;YxfbUrBffaW+*WpzO6Xb^*_`fqsqE@+{*hxT9eV+E?b%|rysAZsF9xv
ztM|_dqAcSyyP1&22EDTzX=3V;E<V-MJSCAXYg){I$Sjmp^_VI{ZH-4%Kq(fIz{!eA
zXLRjJ<(GxN<4pXHtVYtgiiyt!i}?3KC6|N?-z!z<quru(Da{rBz+pwMEKF`&xbcTJ
zNQcpBDBCqQ%)!AV8=K>f(jZdYe!(n-S1~VQVnDZk5RWIC02xZEZW0#=>k;#WPZ~#H
zaYN}97b8u3n~`F<8tFWx!y_-_m)e7EyN!~iD_()`;U_(&Gu4kOXyQg<R^kpy$1IXM
zHe61(9u{<m)0vWY_Sc>3b<yMH_n|;fk)sFC>EX7t(VtzIE>vx3hEV$C=_UJ4iS2}E
zU4>rM&M!l_oVQxc<9q2!<E!Q;KXu9WsBrAPhe$0R9A}RWeHy_kE9~F;vn^+QK9wYq
z<VNZ0ytf8zPFIPw`m6Wa);pKmE>(pm3ISl~(J%UR`@6+OMXE1Vb)9@=cSuTy4BEnG
zE7~p_AueS=d=SVPf2{w|t~)h@QZBg#RTP><m}-K%^#@hK7T5M3H3u5ki_CN!5+b&?
zD4Zu-8h;M-a0(C_9BkP^UBx8?Vz@)8Cp-q90SXQz=X6n)NGM&bws2<Ii{#)z{58&z
zbuTT*%`9Y*8G0<~$eqn9vvQ@W5)W_<CQ?cel#)YzHTOSN7~?(;dbxyYtC1PR9n?(y
zD5SryWvX00B_=KH`7!2u;dq74#<Y-h67psOKa={RyO>pC(9w^0l8JaH7PSMIyg3mo
z@$T^-cUtdiG%7n4gjh%+-EPnA&tem6kevqTdYLi#`uJumxVW%=jpQj@Lnn>=gh0Of
z=S1O{-uG)Yp3xIBW0I@cQo?D6)ohZBnSQp{o2zUj9~`0v3nNc%eShTM=jN|r^C>#t
z!(~%JAli2F!vqhSdo8vc%E_#Q?k<6!JY6?MH8!>wc?KuGeNTRiM4z-+wa)@_fPJ#8
zlQI`&uU@00K<3mVa=coq*%`p<9{k>u*^6BX&B7$~O|b}L=&1{nLe9Jcmo35Z76Nvb
zXxxFasoVRD)*5~0RS*~+|J-nCU9kQ*kWjHb_JCb_qV>bofgme~3-(?feP2FPu)i}F
z;Y$Kbx@n5mqj)-zvrC1$;Bx=7YDPh2_(n+cbth-ZtmjW8m1-B|>~DPf1>*&%?+l_5
zQ*|7ja$lmv5IT;((uwf(Rc?R)&ZGucd70o@Dp4tdkwYv^_HYF)75--#U&pvi{}(6i
zt&qWF4=SU_@mB63BYE3F^=6BX`SiiyXb}Lx$HqPKP)1V7B#P9fqNwTWh4#&HbKn_q
zwO<_SqTi!ivX9w494X_#%<oDzvH`;KR<G2uqcgcB_8e2JDg9L#riS<M7%w-<tM1%8
zEg|1j`V?<%GNCZ`Jl*#2qY}iweSfCW3dAmv2fb7Lq@TrYHXx3B5~{ZoGuRiMz-CqX
zshZ&WBdcDJQ+<#QOgzy#bMhm39m*H(#&y*${Lz;pi;eG3R~pUTIHJc#<8&AruY~4V
zWci_Xgd7wtgX6~<I=-ytjg*jidvS!X9~?rZ%Zc6mlgSneP@~{zSxTz<+H0(1zisCC
z6y#c`r0(js4q~z0Q;Uh9lwB^2dbeXgyhh|l<_7pHP`^w;DHQ;rD>`l-8<>YOL1Mq3
zaU2!{&nM-{r9D`-C`&r)`TliaD$2}`r;C@3LI%=nfWNzcjDrSsr+D|kLZ2^|+IL?-
zFL@xDujfmetTD@N<=5Ovr;A&vfDYC1AmLXA;dA{yffE32n0rtCL!SoRv%(Q(TBXzL
zeE0WEs6teZ{8(g?6($<n@8-tFfCsv&H=hOviqAaCYa)%<8ED_c_pK9G%K692Ln_|`
zKbNh}GsA)hwGBqz$XW0SR(>D7K3G(GVTm9|SsLW7xwo_*?GsJ%lT)*HmD_vaipHEg
zCRP=wDSEifW^fjPofsYi(PN|ch8Lc~%R2>80~UYbV|KuwjqlAJez7xcrf>J}Z8jTA
zLu;wO=jDSdgcw<g5FJkq!%9WNmr$HHdK*ll?tu0KZ~5_C&K?GcIG9XfioNNYA1o0-
z^5p8Y`T}p$qhtLO@njSQ*d{h}n+DCAtPQV{<-}n}U=66Qdv=VQ>~!{Nwxgq?9(0*D
z`hEH)3O4)oYtFz@;u(B?P4{D=e3q6Z<;L5rz_CEm2K!}ymYTBai7itq=F(z1j@h$H
z;Q~9tWb7Y$M-C0gqvK$HP|_c85{50I!b!^NVS-Sic^zrN8bQBj%O2-);uy}Y6l@`u
zjUe4H?VkAXeqxpdB>gSTDjq$s5@WDnVeA#8npDx<QyW3@&Z}P<cG@6t7%n3o!%pAc
z_!PNsMy~$hvbaQJ266k!s_n6A&T^A^vAZ7d{t<!QmNhmO3b#&yJUJ+0HT*c`m=fTX
zwSkaFj3uS_4&?%+CYgFzlDhI@X>5hb)%Utd@W%x}KwQ~Lfc&~?{UZmT>itNNrsBmt
zol=jO3BF6eqEjlYGBKZavJc@Oe}pAz=Rd9um7F9S{bCoaFVHj@70a0+-CT|yXkXZ2
zpE~7Zu4v@MtM4V{+xna62H=W}>$uY~UiQlApwV~i{>{I2tK|!ojrxa}{P0x~mD`7T
zHQ<3k%0d~{ahpPBE#f)U$MgO!M_%}mugZDLgwTBe5Cf*l#3g?X{RO!;oov!={Yzr*
z-(jT$)4)Og8Ff7Ah=NJOQ=9pGx^q;f6n3}*yD9Y0US95OxTV^XU$kCh>32ir(C5>P
zdj0IcCiH7D!OTNtc(vxm*m83=gYh)w3j5G?=Z&vwx%}xDm@<_T$@c)W_V^LH>0|<@
zNswtJRZ}BjbWfkkZRuL=({gz$xkAI8RhVN)=pL8T@KEJ|xr6x*BZs+XU8y6fAOmzP
zH=M#=@MoJ$g#&LEEL9gKOvcOMO(7(is7kr03vRpNWN?VIAzg`zbfxUo4{iVwn6a@B
zhEOHR5BoLi2q}>H2<tAW0Qzk|r@F6m)edTsjAUw+XpxTW>x0pIf<7w(aDRM*Uj+M;
z9~tMQq!i;&N!xC(uw2=Bt|M>P)^i%_a`FY8T3p896#DY5LJq~R1x9|n%-O)DED_^c
zZn?6<C9T7E){5OxRpEg_i>S=06jq-B$!4LyR_oH)YHfpWcdKydwB|u9B08BsX+vrb
zxr{zfn5()kY))w)>=YGG20GED$qrnSfTy57n;%Hwq4|Gmiu8K`*3+xM>n^tm*LgE-
z#^t8HxqxZ<17eBmo2`1x_fpez=5-8#n`N??Qgr^eX~`9usXXB4yDIfd_wL<4<FhF(
z1te}U`|*ok9ONT*y}?&C7YY%Ar|^AxRGL;<*X^{e*3H94j5lIK+n0GenKspxk>7s#
zb;fq~Q~<AIvR7F;BIHL!Dqd^k9d&{g`b%UQ=j6g9i^u-H@3J<Bd5@bbugtgXcE9m~
zC1164hnd@yGQ+Pg8W*lpD4Ec##n_iutx;oV_~Pp2hGl6wnfhK{Ek`LRj7d9<tWQ4b
z)F}mat#htb%8(?gKRlMOdTVyA*LuvWhTO^|Q8Hq4Rz6sc6Dz=l-(TI+NNs%L$AKn>
z7f^~2_3M!wU=x1Y>;>A+E>DXPXwQs5HUuJKR}tDH0`XDuAjZD-BDbA2OK#U*7u>O2
zk-Iq9fV!uhrK%x!u_DPG6~tHll-DEey&xFmY9&7|b8*5kFIl4Icg?B~;t@&el6v11
zYfUCI31MI2*$9KcBKjqrCgoW%bY*y;0HoW{6?vH;_(99CN;XaLF(bd!WOBP!QuQzo
zrHwhJM(H^jC^58@kgnB^zLu;+Jx##Q^3|Dd1iF4{tMCSmX;BIr^9MN^Ob6xTZ`|}F
zFz1jz;+?-??|-t2i1iIXtJ~q)=3w?m_3p!g5UW3Wdm4FYT-Tmrsm<pWHs35XA$jjF
z+vXhjK>di=7AL^uzcY)UTQ0AR(qHcaY1n^|_9JyDH0hJ|p0^azw_(U&{AYF-N6g$b
zqpgAN*E4!CO5w@bE&$}vqj`&L7-rtfNZq>j*vbmuLoc3g<X^72ksZW>do(gquj-pc
zd;880LYF-sWpEby*x9npzP+hQjwad*k5%FzQ<CWE@>le-ufM9Rq`(^*ikEiDnjD~G
zXE!%v7tOrjY)payVj@<{P9-B@zKlY8wo0-H8XZB$vxf<>jqTdhlA37BGs2XTczqaL
z6oT3bbw3!-Dv6``7JmB~#E@0CQgIQoiNBGeZ0D*>UnRMD?mC?@#1${%u|sc{843_(
zJ=N}cK-U)Q@()j=dnvJdxU9FQj%4*Rfe-HQ9kuWF{TsZI9M1wnKi^<jOWW<J-{K2n
zkRg&w3j;St!P(%}$&(LW<?`?t7s24W6Vkes&YqM8_Ihg~CAN1)faNx>Sx$|4TDU>g
zexbf;s8OMjdkBBh8v521iY+90g@!)bsU4wFE$A9k+GE%+6O*6Dv#%M5(BkeBWN$Uf
zRjp3g5oOi%mGcHQ=*-N%nR#%0?Rg%%TN7W^Xk1ZIv5k;wcAv?<99L3=dpZZ2GHn#8
zujKj*sR>WxKIfZs#DYGuGQu!h;c>l<vYQY+gQ4%`_N;jtfcoOHGR=y?v;ci=1`_<V
z?&yzdIClp`JjSOWZgjD9xk$hpZ)Bz~T?((Ven}3Qco&~AC+_AX7HCqX0jD&^>O=rY
z9_qy1fNzg~bWc;7wUg=;>&GZvk~RI_`Z~JkmAk4~Wz$U=CpR6a!`sBmF6Cub*ebfo
zXKwmz7)PBS7(pj#oz>ie(l@b$tgc1aN>r|F*O-{5)M79i*5D&@Xg8%QwR&%38Y*{W
z7C-9!khV-<^qu)_?y=q7_wU<SeD)}mLo(n^_X1^S!0k5Jb|s|Xz}YM+D#{{8b6dI$
zO-N~nE64PMop0?<JkE{5w+ERy=22RYAdCOuBx@`gKXkBh$-k#w==6A4GT!mJI3xSU
zAc%qJvW(amNWYo8!KEE%U}kCKG#rg$`j76qrUwol1ac(m+e(c*?`0-Bn(0(iOV;?s
z_!#bm;IUo9VJbU_&NRye>PJ;(uCD#;H-Qck-#C~09}YzOz2c)KKUpH%2paQ%Yar$F
z3+yH1*T6QC_QfB)>PHqQ5Y=hdi4txLU9I-lB@J@2N{>1y${FFp`|ZVcoVZK36P#Qf
zp%R*mMoszf-ltZTsAHk%%u*Ia@v5-BSB}#L>N4)P!7$z%_D@>AA7aPq$D96BK&i-o
zF%yqq;ANAhOYKea!Fszy7dv_=%30;LvodCIh-a-u2U{4IuE!a1WY~gSGl4Yuqo|k1
zOa0$uyIkw$w28gUC`L;C7<A%Qk5I1p;GtMz3(_FB#E598=ia}W<6sj2nqD)R6zBi3
ztTG0@q3<dvn6L}3WA4%L%AAHChj@paoMryO67-DGKW=crbBaS6Kg~u7|7p+!2b7*{
zJ}LT9U$gtK`dSYiR%0c`YjqdgR8*jOQD@LuHa!vYtkPDY^!sk=1#*Qm@VEsWYd0%f
z?h9@2D(r~l=W=<gCDf!)W_YowZYjH4svW!X1U^q;P>;7MpL`P67ONE6oaU$00Vvxa
z%(c0=5@%t+$+x^&q3b$(oLOEmU(>Zzn6u?dE5}0QOdflSr%*C7QzwuPVYcMcsv}9i
zHjsarnbUFmHax&6B)XSUHuVm*c|_?e<kd1x=xg2?E<iUdOtWI<>u|;>p3xSUP7`Kd
zg@Mv~AmE$XDRR#D@JMoPA*=aQ=|-G(;UsEG^2o0g{Jpr)zQZD>dubDyKR;wQsB^h*
zcDV8-3iIt&7<UnoV3dO6%(pG&A(8#?)n2L=TKvp$s&EBhMZ^O|=kXfDBl@v!eY+n(
zMjJQmr09!d*^AS58A1aMB-%<l2dei6`eS7|z70poO}8ok;5?$qSZ)3V3#-gAGiX^o
z(7Sx`%4=bpJRo4CUIx8&2)>y~-jVmQQA)>SY>jpVF8F-)41Yss7cgrvlWdEx^$iWY
zA0B7{CueupEjycGSqiGC+1c4gzv?~Sow4~*Oy?BBiv6&9%;dUYR=Up2J>G0T?OTFu
zroqzX6D4`<yNH!+vTguN&mnSde_B>iUb@85-vUeyojDwLO7fCx-<=m%tZThTRxOfh
z=G+S=s0n3nPJQ~sh-4ErMm$+)4i5uRNJ91hO8tuO{>8`~{V?=)=z6;WBFfzzGiM<5
zQ17bgte3F+-znnRIj7JHenwlnTkv|xL;F;+sZ^QfXU3Xk(XG%6RNvCqOdjV9%8R@F
z;csNsHrk#SWk~HI`!fj+^YVgvm;4nfDogD=nzRSo0+d~IVlDxctws6yT`WF6J|%Ej
ztHVso(V^rJ($$+lkTko5++s@phc5O>pYi5@&x`6=`n|K=iWtkLg9-TwLAJ4n&^US}
z-KAPLCg4Bm)7cYy3l|8KokmaLTw~w9r53W9GVAhljU+^>rbq|jpEX%b3I?AM(*HT0
z&VUyk{<-?kH$Kn*Kg8V&`%8+?H0WBlb9^<2<DjJ|ayO>6_GdnA@wHAARV9z^bcGnO
zZBQOPSJMVxQ?=OD!RGJ7g7l7j{fm|@gEup?1BT^&xZ;kV$A<b8xhHuq74YDzNTI7%
z|B$MG2;o^IT6?RuS&cvv(rYPH=zQ;y-I^m7Dl}*D<@LH+wX%`XD?#<<5Yo3H;MWIS
zAb7}BOp|*2ZtT@6vV~atf#hK3fnVosdaWt(ogAfL>*XPk#lbF-Dfm;X7N3&;a%hPE
z>|m2RVP%l#^nTHK{nnbUz@1RR7xNA&bb_Hu2TJ6@YLHJt{vBkfwSZF6uISG%d$-g5
zyABl~3Z&Gisfts|xl8oj=wVUP9HyJBSztK?2F5AvAV8L=66L9Ouc~uL?mAVcbd!OY
zpxp!0P)zeRJr3XL#E`1aM+M)1-oN{pwG%a-sWe)CzT0obgy5aH(S@wQlPt<&LkYix
z941|?J<K4?6g{w>$|d^v!{&VZRYP^-f-8(w+i{p#ne5XgQ|_+`v(2V)z-FuF%{`?x
ze8a)CY>0b`BnDNCif0P`T1$qt<=<(gt#Cl-y6F;zb0Mqbql2;aaw{In4x>W9)psx9
zr>Z|GDb=$dRJ_lUmFGqwq%ms3)g`AR6v8DOa(^3RaqVz+V*ivhBDOZQ(>~1MA<J5-
zUEO~C9C^E?KsY|%Z+AJ)8V!LS60n`?QyU{Z+K5$;(<5%OI!2_)C*#Q5bEICRsnsQg
zKDeVQSHRtSus?9#ot)Ah)PB;i#xjFv4*`{2X+V%;_q_>Y4)$cZT`B6Cz2y*H1irVC
zVPzq1^XrCu%aLhQFG3js{O|x8ysi{7XTC4?lUd~iG6BJc&drzrM{E6qFAPkar`o=K
zRge4)Pq!oNLiQvtb$h|rnx7L^t9-LYaK5eiVkh0jj{;_zUxh&B$iFC(o*^>fZ#m#c
zTSvP^uw5Oo?wBU>P|$9~OYCZ~adUR7^+oPh<wU8U+yPZ3e<ZB>a5^Z%eNUEKV0JVN
z>aC!n-bNnmUmYssvx;4Xa{EPRk|#`eNAe-78H=a2Q<;pz*r6m$Xu)>`v^e6F$v0+`
zY#rB*cUrg*@+~iH^6uc_SDqE{%pH0DmI_$tksTS69o3YYwz~jx&L<v`!rP(7b3E+@
zqyx#H=W@5g<*jWCBcFQQbgo!1Tph%>`dK+-b1qe`kbt?#FkPO(YZb6T7qVao96EgK
zJzHBrGV^o(^{a3Sv;dL^H2BT~U31fquiJ@`-xc6#GH!NnRtHH?m-Zs|me)M+N2kXS
zYM8h21N#jiF=v0HN1>@)vN<%L;Cr0S9WYO?*bt=IR6$V()O@;p^?PVQ?sxk`r8;AV
z&|SccAHifMbgH?o6IXny(^hfET6blBzARmKix4TRih-Xs)Nkc4_@R9cT1gAOuzGt0
zj;r;sw%=vHWMn^%@U;WFe>B-THKTGP;DI|(J#c58I%LamQ=%*K$eWH!k^$dAT;jI=
z%l|ZfVb3JrR<E)e#&I8~1*P36onavcwikryLUli}w)89HFwEjyi8XD^2k%%OtafAf
z#2&YveAo+}*mEsYIvztw?WaMB$atlR_X2UJZQ#Y(e$rSakJAwRtDMrIl48K|m?ekZ
zdRe4`C!+26pnkn$kF?daAiE#AhuSY9psQ7(0!K2{-)pjeYZ3GTteu_^2t)MhrjJOu
zC#8gxO5D%RMz3O6CA7^gV;@DCSW%QW-)bQj0>5D0s7+K1YQHe7+!XIUQV*&l9L$jN
zg1AsA`LQY?^Fa*w?+e<Kknp_k=JCOIoY%Of;DjxPmHycv*yJSF4o!ea$s(iQTCYco
zH8j||@U3CI``0mfcXXb$+sK0I>{6)C<VWE8P~Hr}naFjgkrtF>9#^pq-R0&w!Zf4x
zT^0Xoi?<S1gZA#sHmE{t2!5Q({Tf8&OCghO#ys-GoY<K4_|vvyfaOuiZ^9uKHvxel
zU&@r5zngnF&F#c~#>MD$9xWy5im-|XC+9;g(fyT8fiPdC`C!Wzn5q>wg4AeB#hvE3
z6a+L48`T^#@p<)*^=S-*64U>El;5g22<Rrbz{(y=Zd4MTbB^o@M(T*-1>kII5T*S2
zz`9wJr-!b=V!9r*w<YPf_L7<=q}Er;>D!iD>=lPr_t9+KHd8l5KvBvkgf>rT(}cV<
zg^Bq#3vf1DdIggF#Qf^}`kB%=U{JVkz)@aE^K0b#(94M{FYb(6gjje8jVFV$8$b^#
zLynS>Tt{s$X1%p0f8#g^4LB0P<;@D2FW+rPtRGone#4kPYF+n#6<7`5X~hTT-)mY}
zUiV}P@*!XOUyFXr^f`WN9xD@c54J`w37ty|UHYs{-n%HaGVRjnB=3vUVCM-9MEJ_9
z{@xaBK6~P-2AlHHIs4KD5?^DV4kUYIaEE+0ziO^^AE$ESSDF=9vGTrl42dbOkCWjp
z;uAf!5QBv%Tc5g`-E5s5tn9#X(>Tq;MAx)&pZ%r_$u7~hASbAd@pRWszlNy%g!Zxf
zg<=%XXbtsMX3g@+mrviV7Qk+#{^4`Hk+n&FFC2IXOWwsW6ddIXlt<KF!kwd@SRc_?
z58Mwui(8OG=Y+Bx6Z!P%o!Uka7jg;U1yb?~SK2uMsOFO7n+~QKc4MkIFgEe|tf7Ts
z_K)sld02fHHHz4t6?17K0%kUkU%s|AX!jr5@~3Nyokd@4A1gh@q1=15wH}Sp>L!~j
z#<<KU9rk-=u>~VmblXVx$b;RIgcii^q$cuzcB}u;n-6)r^Ek{6xvi2{Oo3KFAErg2
z0CTZpJFWIW#az=zep;x515uypIseR-a*vRCRZ@z_2|#`|NdWquvHLWxEY-cg&EBV6
z_UZ-&RZtua`1npqc+_d3$MH@T*N(^64Tc7xAU<{L=F^LTn}$`Z$9HB;ZZF<aXgvUt
z7k7ZeX<-O1&DnA;1{rQS<4GPJ<GL-?@GR;!kJV`$H0N=l7%v&0aa!nbB5}i^R$eaM
zi$Q7kBIzckXM{4s0kzhMI&BX15m#Kj=&>eHwLE#d%K|p`jBX-%e}kPg#Xo~j-R+v-
zQ{1uLRQ#|dL}8xTVdm^-HvNP7cA?(bt?{LZW~(q9lpGVpw9>>Uukk$zgZ-MOd#o09
z9km0<XzfV9tW5d$3tiXJ9zM+Ny@~g3kzV_Zu^vK*wJc<nX4Hg#9VC4mvci+{j~GP%
zZHbg!jV2MDD8kB;$H}z3ethC@%J75pgwaeQFwmv`qkcR#cnkfRI`*`o^h2$IDQNHH
z{mr35l|j1D5k={J5;JBYWAs~~W#pomrl49y3(%|7aiM;ri6Gj&0Bf!E@TXAhc2Pi#
zvgzKAiQ;q`30E11E#-<er?^h@Il%2(6}oE=CZ@c0ST>+zira@Av|>e(*s63o|MuWT
zdU6S5(UWX(x@}pI2WZc`13j#--)tL_2Sc1V^c_RB$S3x83>PWoG_rtHJNvNXBkJAa
z`>Qur)&BgJ=C=_-oJ;Yx{}ggr)~yvBezJJLgYO5rqEB9C1ke5qT`SYCM!~99Vra2W
zf*z;CvRB>PW(b}vt*sSNw4G5((CtzP?+{1bLYoaW!~-8JowvLhiol*GS+SEa0L8<O
zX~#P2(4~7JUB+L{wU)^543#<JTp=+HW%AgC$qNqqvcj2rqKBbkdsS1j3s|J}tNF@q
zyRs%-VPaoVTM=qQE~URnY*ia~uFA>_g<4j%@D@#Z;s$d6x)C?KG<nff)N(Z9naf7y
z3!z!DN7O1cp&L`cu>qhwf8x@GnLrFZx%Z8=b*lR=a$4%O4(D5-)gGsHCS|8ZB8#Ml
zJj^=Wo>f}5PJs9dYfmAlq-mKPo=pESOP7hk0Ymg@S+NE~5{|PXlYRqLc@AD+^v@7P
zuY@8SVH^Y<d14Yl+1NMJa&ySN@sJ+_=D-rY%d#_%9*{d#{TwL~$0-W@5ZmP0tz9`(
zCtSS)z~u=CwyItC6$B{53MXcgGj_2@nI6xC<xX|QyBFj}vBkQ<gNpHc8DeC!(+$aX
zPthboFHa*aiigH&_aKr*v|)A!#M7V|ezI>>>6G!{uHuRJ6Cz&FZI+ly&mF9FRDWmX
ztE-gs4Cehw#0QgQerYA8lCLEv-dhl(C_@J>H*_+>`i<bhcjB%o^vVziHjN&!IaRAp
z6#2;lzBx~RpT}9$tW6yGd>aCligIFuDR2(aGNMtNMjAb-w;U1+UBA8As?MO~iIAJ*
zO2Dfh`O;-IYVwRHXCyW})wf<Rdu%ix)o#4VbE^F*9JRJuyZMr^uVZR=!atOoy!$6|
zYbgMeS;UPkX^Z#}AI}T3Xd?N1yW1`SA0ArG3tSJt7&?yxc|jAmx{ew47*204b3eBl
z-r(_yG5@FL_G8X>Cn~+RcAD$#Vw$?9unX+`79K6>PZcZsS`n-7-2ILsXshr%N?cws
zYHK22%4u0en^e&v=>)-p`*=ZhjD2ORb>yU0NYnMH?buKf5jgtUC04!7jr6@1`YlyY
zfF}Cjxa%_o%+KLfYeMa$O08uCrmKy4yp^y_^kuEN_vq;8CQrUQ5wsMcA1IqbFAY|8
zjVOOLkYGd4KWz8iL|M179ByvgMZv(V&=Q`LCFPK<gVT3wx7#|3=yBkmq)ydWH`j@(
zYS|3-&U1%;n?YU@4f2)eX)UmBSq!!;KvsCg$dW7`>MC%e8LST~AkHEFtC+x!!vjUo
zo)T{1YRkSRE{_AgQ0XTtVCzGnqU-ccP~J>`YTM-gCsezT1G(0BeRRlSBSx%sZW4jl
zh55u$-tIVF=hv16l8Ga+d8xQ0SyW)p3b(NKrQd-bpDT}W(QHx+>`%^`^!py|SDg;O
zdDJcJu?in(JmN8(3ETMj1&o|1{XVf*p-X`+3l9j!s?9F(ysOCq`zuNg)Qd~~axm_K
z@klPhur{*0{WxYvzc1W<<Yw095Y%Ou7KqUmmFM=D%2jRm$^(BUwfvv<&Go6NBMjrT
zoz_8A#%g7zZOlv&gM+|mm57)`rHB!SstlrHk`7d@gcvmfl7MNw-$*oS@xrY{kufGg
z8K5y7;uWbV2P6==gu_J)G3El~<m7&OsQqA=_CIhx?d<G_-Dh`ZpZB-#>l(HRQfb1F
z-I{8|@CcFaJDFKQ);6&my2|+_%G+TAYF#!Y{(~?zs7P~BtC9#w%6KnML1izjzdfte
zo}=58oQsxv8n(wn5>xstc)-@P*jxsM-o5PAwQ0MDx2&P?lCEr>w1c#QXPaY0VpS`0
zLEt}e4>YDueEvL|UE!i}A*fIKNXX8bUD_Z%1GyE4M7+&#y*LDdr*Pe;tf6WpBt`hc
zd-4bHeG=r}@iHlm6Y1@S?KYtkKBmWU(O|*hZms#HExz{c5r!gGh)Nhj%K2-T+&B5{
zKXL+ZC{3+5Rie2C2N7jQHWuMm@QPPM7%TjyK3v5ei+46An3q-bmT85M#Dm|r{?;lN
z*ejlbI|i~FtV4I#<n^I)ggMfM%WyRn+<Ovz*98zWbOiJW*@imcAXm{2oq5Cs38LqU
z=VU!!Q5NYo%=PHo(N!$GVq=e4TV7muV;9|9LsuHLTr?%y5P;??4Z^91M#~MGeU<XN
z$ifaAc1FTdxiTK;sAX}j=582^-PMJ<?yP>WcDE$mb}1l?`{pkQ`#7{b1mQ7ei$5^~
z9O7T5pP;B2d1_!rjR^+bD+6T4^R?uv1pa8p0ab;|_9_JlwY1GQDu&i58jpJ)7@Yi|
zBHr*903t?qxQ2#YoeT1Q2gt_DRJlAD-v9#7O;1V9MaoCO%9@3&=4~wq@VaXkk%=8x
zG4V^Mm$S4LuZLghLNSXj4eY&Cw}&Zv`hv*JK_c?qX16nvBN)bl@;rAU>0lx6@ffis
zLeCtMQ7fs$Uktd^VZJqSV&3v79>cVytMmG2)%;48eIy&q^^`Y~*^c@dKH~go%FG+(
zaMeAi4PjSa98H6^+wXXL2vIv<Yx++mnA-Bkx3?jvHyJtEv~;1pKiUHZuz7^ScPD-u
zzv{ZeS&}9{I!EAnMcQBY6#ML!+zEd`2sUXfto9S7K&*1H_)X_ITnQF>WW_~N5LMP-
zlD~PH8mNQMR8xAZ#+Umnrr)_g`E+T>g6u(pb1)XtT&Z3JWII@zwXG?l6wFx8%=b|8
zQy9}8f5p=-YOi2>*AvLLSdTowKjhobfs_csfzfwyBrS)|h?$w3S&#;8`ySo91s$#q
zs<FJ3!#iKnn({&%wHUNo2T@$78@yfTFg~_4RkUQB4_t5Kb7SSS780^<aR*);NZVjB
z>;oJLnxx*Sq*8hTD|bN0bw-10M=&pLZ|@L<(XP?$&4sY>Q**8!7ZSl}V+PUN(XSO{
zm?@C!O56oZf3@rhcy!64v0D#=4oQhPo#3`rL2w)KZ}lZrjbymFAV%){V#~s&i_YeJ
z=a;$eJ=zO*Sq3?}sostEvkd2BtjFY03zAMVGSE!ElaAwAbLLTlP;XI5^uQ#b=NBWx
zva9@leW9=I=_~eXQn|*%yXO0-?KfwlAiwgNRF#wNWKiSimgg8s{h-}1f6pSLZV*hJ
zg?Q*q@!P#yp>8-hoJ(MDa)G4E{FwSAP6Rn85nQ1!zG_Z~cpC!uTsYtmk#kV6eiE{*
zIzE9}lO2s7omD}@F1RoB%3Ssz)zbgc&<_?h(ao41?2Cc1vC4o+X!zsUgj64O`CkoC
Z$|ts;yY9`l{gXFGjZ6GNw)&^Te*@ERGByAJ

literal 0
HcmV?d00001

diff --git a/docs/execution_history.txt b/docs/execution_history.txt
new file mode 100644
index 0000000..9fc8fef
--- /dev/null
+++ b/docs/execution_history.txt
@@ -0,0 +1,3 @@
+Name                                     StartTime                  Status
+---------------------------------------  -------------------------  ---------
+mohammedalfakih-dev-weather-job-lq9lmww  2026-06-09T22:20:30+00:00  Succeeded
\ No newline at end of file
diff --git a/requirements.txt b/requirements.txt
index b5d18d7..3c2c3a3 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -11,3 +11,5 @@
 
 # TODO: pin psycopg2-binary (uncomment and add a version)
 # psycopg2-binary==
+azure-storage-blob==12.24.0
+psycopg2-binary==2.9.10
diff --git a/src/pipeline.py b/src/pipeline.py
index ef1fc8a..7e3fcae 100644
--- a/src/pipeline.py
+++ b/src/pipeline.py
@@ -13,78 +13,183 @@
 - Container Job:    Data Track/Week 6/week_6__5_container_apps_jobs.md
 """
 
+import json
 import logging
 import os
-from datetime import date
+from contextlib import closing
+from datetime import date, datetime, timezone
+from urllib.parse import parse_qsl, urlencode, urlsplit, urlunsplit
+
+import psycopg2
+from azure.storage.blob import BlobServiceClient
+from psycopg2.extras import execute_values
+
+
+logging.basicConfig(
+    level=os.getenv("LOG_LEVEL", "INFO"),
+    format="%(levelname)s %(message)s",
+)
+
+# Required by the assignment: silence noisy Azure SDK logs.
+logging.getLogger("azure").setLevel(logging.WARNING)
 
-logging.basicConfig(level=logging.INFO, format="%(levelname)s %(message)s")
 logger = logging.getLogger(__name__)
 
+SCHEMA_NAME = "dev_mohammedalfakih"
+TABLE_NAME = "weather_readings"
 # TASK 3 hint: quiet the Azure SDK so its DEBUG output does not drown your own
 # pipeline logs. The right call lives in Chapter 5 (Viewing logs).
 
+def ensure_sslmode_require(postgres_url: str) -> str:
+    """Ensure Azure Postgres connection string uses sslmode=require."""
+    parts = urlsplit(postgres_url)
+    query = dict(parse_qsl(parts.query))
+
+    if "sslmode" not in query:
+        query["sslmode"] = "require"
+
+    return urlunsplit(
+        (
+            parts.scheme,
+            parts.netloc,
+            parts.path,
+            urlencode(query),
+            parts.fragment,
+        )
+    )
+
 
 def get_config() -> dict:
     """Return configuration read from environment variables.
 
     Required:
-        - POSTGRES_URL: full Azure Postgres connection string.
-        - AZURE_STORAGE_CONNECTION_STRING: blob storage account connection string.
+        POSTGRES_URL
+        AZURE_STORAGE_CONNECTION_STRING
 
     Optional:
-        - SOURCE_NAME: logical source label, default "weather".
-        - LOG_LEVEL: not parsed here; the orchestrator sets it via env var.
-
-    Raise RuntimeError with a clear message if a required variable is missing.
+        SOURCE_NAME, default "weather"
     """
-    raise NotImplementedError(
-        "Task 3: read POSTGRES_URL and AZURE_STORAGE_CONNECTION_STRING from os.environ"
-    )
+    postgres_url = os.getenv("POSTGRES_URL")
+    blob_conn_str = os.getenv("AZURE_STORAGE_CONNECTION_STRING")
 
+    missing = []
+    if not postgres_url:
+        missing.append("POSTGRES_URL")
+    if not blob_conn_str:
+        missing.append("AZURE_STORAGE_CONNECTION_STRING")
 
-def fetch_records() -> list[dict]:
-    """Return a small batch of records to ingest.
+    if missing:
+        raise RuntimeError(
+            f"Missing required environment variables: {', '.join(missing)}"
+        )
 
-    In a real pipeline you would call an API here. Return a list of at least
-    one dict with a stable key set (for example: station, timestamp,
-    temperature_c, humidity_pct).
-    """
-    raise NotImplementedError("Task 3: return a list of at least one record")
+    return {
+        "postgres_url": ensure_sslmode_require(postgres_url),
+        "azure_storage_connection_string": blob_conn_str,
+        "source_name": os.getenv("SOURCE_NAME", "weather"),
+    }
+
+
+def fetch_records() -> list[dict]:
+    """Return a small batch of weather records to ingest."""
+    now = datetime.now(timezone.utc).replace(microsecond=0).isoformat()
+
+    return [
+        {
+            "station": "Open-Meteo Copenhagen",
+            "timestamp": now,
+            "temperature_c": 12.5,
+            "humidity_pct": 80,
+        },
+        {
+            "station": "Open-Meteo Amsterdam",
+            "timestamp": now,
+            "temperature_c": 10.8,
+            "humidity_pct": 75,
+        },
+    ]
 
 
 def upload_raw_to_blob(records: list[dict], blob_conn_str: str, source: str) -> str:
-    """Upload the raw records as a single JSON blob and return its name.
+    """Upload raw records as JSON to Azure Blob Storage."""
+    blob_name = f"raw/{source}/{date.today().isoformat()}.json"
 
-    The blob name must follow the assignment convention:
-        raw/<source>/<YYYY-MM-DD>.json
+    service = BlobServiceClient.from_connection_string(blob_conn_str)
+    blob_client = service.get_blob_client(
+        container="raw",
+        blob=blob_name,
+    )
 
-    Use the azure-storage-blob SDK. The target container is "raw" (your
-    teacher has pre-created it). Overwrite if the blob already exists so
-    same-day reruns succeed.
-    """
-    raise NotImplementedError("Task 1 + Task 3: upload records to blob storage")
+    payload = json.dumps(records, indent=2)
 
+    blob_client.upload_blob(
+        payload,
+        overwrite=True,
+        content_type="application/json",
+    )
 
-def write_to_postgres(records: list[dict], postgres_url: str) -> int:
-    """Insert (or upsert) records into Azure Postgres. Return the row count.
+    return blob_name
 
-    Steps:
-        1. Open a psycopg2 connection wrapped so it is closed cleanly when the
-           function returns, even on error.
-        2. Ensure the target table exists (create it if missing).
-        3. Insert each record. The pipeline must be safe to rerun on the same
-           day: a re-run must update rather than fail.
-        4. Commit and return the number of rows written.
 
-    See Chapter 4 for the connection-and-cursor pattern this is based on.
-    """
-    raise NotImplementedError("Task 2 + Task 3: insert rows into Azure Postgres")
+
+def write_to_postgres(records: list[dict], postgres_url: str) -> int:
+    """Upsert weather readings into Azure Postgres and return row count."""
+    with closing(psycopg2.connect(postgres_url)) as conn:
+        with conn:
+            with conn.cursor() as cur:
+                cur.execute(f"CREATE SCHEMA IF NOT EXISTS {SCHEMA_NAME}")
+                cur.execute(f"SET search_path TO {SCHEMA_NAME}")
+
+                cur.execute(
+                    f"""
+                    CREATE TABLE IF NOT EXISTS {TABLE_NAME} (
+                        station TEXT NOT NULL,
+                        timestamp TIMESTAMPTZ NOT NULL,
+                        temperature_c DOUBLE PRECISION NOT NULL,
+                        humidity_pct INTEGER NOT NULL,
+                        ingested_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+                        PRIMARY KEY (station, timestamp)
+                    )
+                    """
+                )
+
+                rows = [
+                    (
+                        record["station"],
+                        record["timestamp"],
+                        record["temperature_c"],
+                        record["humidity_pct"],
+                    )
+                    for record in records
+                ]
+
+                execute_values(
+                    cur,
+                    f"""
+                    INSERT INTO {TABLE_NAME} (
+                        station,
+                        timestamp,
+                        temperature_c,
+                        humidity_pct
+                    )
+                    VALUES %s
+                    ON CONFLICT (station, timestamp)
+                    DO UPDATE SET
+                        temperature_c = EXCLUDED.temperature_c,
+                        humidity_pct = EXCLUDED.humidity_pct,
+                        ingested_at = NOW()
+                    """,
+                    rows,
+                )
+
+    return len(records)
 
 
 def run() -> None:
     config = get_config()
     logger.info("starting pipeline")
     records = fetch_records()
+    logger.info("fetched %d records", len(records))
 
     blob_name = upload_raw_to_blob(
         records,