From 3c33bb9a7bb14e6de6753c90903f60da5c379ca8 Mon Sep 17 00:00:00 2001
From: Leo Schick <leonhard.schick@gmail.com>
Date: Fri, 15 Dec 2023 18:13:51 +0100
Subject: [PATCH] WIP tests + mara_catalog.export

---
 mara_catalog/export.py                        |  75 ++++++++++++++++++
 tests/__init__.py                             |   0
 tests/databricks/__init__.py                  |   0
 tests/docker-compose.yml                      |  20 +++++
 tests/example_datalake/README.md              |   1 +
 .../example_datalake/mt_cars/mt cars.parquet  | Bin 0 -> 2932 bytes
 .../example_datalake/weather/Weather.parquet  | Bin 0 -> 21006 bytes
 tests/local_config.py                         |  11 +++
 tests/local_config.py.example                 |  11 +++
 tests/mssql/__init__.py                       |   0
 tests/postgres/__init__.py                    |   0
 11 files changed, 118 insertions(+)
 create mode 100644 mara_catalog/export.py
 create mode 100644 tests/__init__.py
 create mode 100644 tests/databricks/__init__.py
 create mode 100644 tests/docker-compose.yml
 create mode 100644 tests/example_datalake/README.md
 create mode 100644 tests/example_datalake/mt_cars/mt cars.parquet
 create mode 100644 tests/example_datalake/weather/Weather.parquet
 create mode 100644 tests/local_config.py
 create mode 100644 tests/local_config.py.example
 create mode 100644 tests/mssql/__init__.py
 create mode 100644 tests/postgres/__init__.py

diff --git a/mara_catalog/export.py b/mara_catalog/export.py
new file mode 100644
index 0000000..571561d
--- /dev/null
+++ b/mara_catalog/export.py
@@ -0,0 +1,75 @@
+"""Functions to export tables from a database to a storage"""
+
+from typing import Iterator, Union, List
+
+from mara_pipelines.pipelines import Command
+from mara_db import formats
+from .catalog import DbCatalog
+from .schema import WriteSchema
+
+## TBD
+from app.pipelines.transfer_to.write_file import WriteFile
+
+
+def export_catalog_mara_commands(catalog: DbCatalog, storage_alias: str, base_path: str,
+    format: formats.Format, write_schema_file: bool = False, include: List[str] = None,
+    db_alias: str = None) -> Iterator[Union[Command, List[Command]]]:
+    """
+    Returns pipeline tasks which exports a catalog to a storage.
+
+    Args:
+        catalog: The catalog to be exported
+        storage_alias: the storage where the tables shall be exported to
+        base_path: the base path
+        format: the format as it should be exported
+        write_schema_file: if a sqlalchemy schema file shall be added into the table directory.
+        list: if you want to include only a predefined list of tables, pass over a list of table names here.
+              This is applied accross schemas since schema selection is not yet supported. (TODO Might be changed in the future.)
+    """
+
+    for table in catalog.tables:
+        table_name = table['name']
+        schema_name = table.get('schema', catalog.default_schema)
+        if include:
+            if not table_name in include:
+                # skip tables defined in include
+                continue
+        table_path = f'{base_path}/{schema_name}/{table_name}' if catalog.has_schemas else f'{base_path}/{table_name}'
+        #yield Task(id=table_to_id(schema_name, table_name),
+        #           description=f"Export table {schema_name}.{table_name} to storage {storage_alias}",
+        #           commands=
+        yield      [
+                       # TBD: when format is parquet, delete the folder content first
+                       WriteFile(sql_statement=f'SELECT * FROM "{schema_name}"."{table_name}"',
+                                 db_alias=db_alias or catalog.db_alias,
+                                 storage_alias=storage_alias,
+                                 dest_file_name=clean_hadoop_path(f'{table_path}/part.0.parquet'),  # TODO generic format ending would be nice here
+                                 compression=('snappy' if isinstance(format, formats.ParquetFormat) else None),
+                                 format=format)
+                   ] + ([
+                       WriteSchema(table_name,
+                                   schema=schema_name,
+                                   db_alias=db_alias or catalog.db_alias,
+                                   storage_alias=storage_alias,
+                                   file_name=f'{clean_hadoop_path(table_path)}/_sqlalchemy_metadata.py')
+                   ] if write_schema_file else [])
+        #,
+        #           max_retries=2)
+
+
+def table_to_id(schema_name, table_name) -> str:
+    return f'{schema_name}_{table_name}'.lower()
+
+
+def clean_hadoop_path(path) -> str:
+    """
+    Hadoop hides paths starting with '_' and '.'. With this function paths for tables are renamed so that they can be read via Hadoop.
+    """
+    parts = []
+    for part in str(path).split('/'):
+        if part.startswith('_') or part.startswith('.'):
+            parts.append('x' + part)
+        else:
+            parts.append(part)
+
+    return '/'.join(parts)
diff --git a/tests/__init__.py b/tests/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/tests/databricks/__init__.py b/tests/databricks/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/tests/docker-compose.yml b/tests/docker-compose.yml
new file mode 100644
index 0000000..1dc49cb
--- /dev/null
+++ b/tests/docker-compose.yml
@@ -0,0 +1,20 @@
+version: '3.1'
+
+services:
+  postgres:
+    image: postgres:15
+    environment:
+      POSTGRES_DB: mara
+      POSTGRES_USER: mara
+      POSTGRES_PASSWORD: mara
+      POSTGRES_HOST_AUTH_METHOD: md5
+    ports:
+      - "5432"
+
+  mssql:
+    image: mcr.microsoft.com/mssql/server:2022-latest
+    environment:
+      - ACCEPT_EULA=Y
+      - SA_PASSWORD=YourStrong@Passw0rd
+    ports:
+      - "1433"
diff --git a/tests/example_datalake/README.md b/tests/example_datalake/README.md
new file mode 100644
index 0000000..fea958a
--- /dev/null
+++ b/tests/example_datalake/README.md
@@ -0,0 +1 @@
+The sample data is taken from https://www.tablab.app/datasets/sample/parquet
diff --git a/tests/example_datalake/mt_cars/mt cars.parquet b/tests/example_datalake/mt_cars/mt cars.parquet
new file mode 100644
index 0000000000000000000000000000000000000000..13085cda454c70e716c9a1a7076ba4ac93b86bc1
GIT binary patch
literal 2932
zcma)8U1%KF6~1?LXLU!KS<hIS?JSj(iCJx?t$y}T&Zd>6Yp<+0MNTC-*r8FBjCM!b
zA)}qu>`IaC1XO}eFb1noOdRsil04+WI3X^@kH!Jh2f3tAhEjq9#RQx}z)eU)TYB!y
zZY5y{I&if2oH_U0?|kRnGnzg$o7Itij_UVf13H6cOphV-CYcftLJUjr_n3XUVw<xs
z6qF$aZJH<Tr7o~e*v-aj&3r1GiGz034{A=+ESM94yXI)gz0V)7`$5xQ@K>9i@cxAD
zxpuADg_*h9XgYzJKadeU(+SFEu8^6a*b^0!&m?73+}BTwnG$AVzgif{96yqaBQn*k
z9m0KIm8MF2Ay~<-xSnU1%}LL3ny>kOr3b82ZmsNlHM8W`nr_XhHEmDh&eh;l!-Er_
zU9LNUYkT-y-=u3d&1|lSU$Tz+HAt@HuDNCWUEz8El-~r^4}3V_iJ$D-OKY}@?-%{b
zl4F*tw&yvuB`3g>)}do1^XK-O<GD3_BUQ4O?Z7vG2{E(kG)I6xGTgvfaD&Pd`^7iq
z7qWv-<8ooz4;tmFV?LcN4CZ8f+wz;M4fDuq;MZ+@sW9mW6>}Phasu0&!utm%oglCS
z*PL)`J}y;{*$sHpbj`zlVDl=R@VzzP%ocJ-pmZ0AepA>{#dCrYRS}7pj4-iNMI-F?
z7RK}dTNE)JVR?+rYdQALWq6VbC6@;j6BYFgev;<%c|}E8&@+;XrZg1|Nh;Y&=~P@I
zi-QV74Bn4{?E#bCCL1FXC1@Djhont%`Nxu_t&^#rDHi%E$Qa15WRYum#Y_#c#qb&7
z?RG)X*LOn3sR%MOA;JU^g(A9-;$BR!3DWl*K{z!;&{ztM^`QaoMnMQj#K51vmw^f}
zpi}fBKsM`uc4H0xn4U!CjWxE2v3g<wm;iQc&I@@^(P`i9EqF#(*ce4(m2A8LJ8rzr
z_nv`lt{jKem$T9<<kk$VV)J0T+mHYcP<eM1=sCsxk4qb*XI?6jTPGz0eWh5$T#!`j
z(|`eJxMcG!9{z?OMMMo;fQXkAI{hImU68Lq#z0;MIinEzd&r&CZ-aIR<Q~XjkOIgd
z5F6wYc)>1l8k=)3g1!PmF+x1zFW`3>ek1z+@<{sf&_H{51LgOG4P?gI`}Koeciy9l
zk&;;N)n`6G-5UdkiK`Mjdw=HoV`mjMck$-e*4&=MK-~|>MGC)Y1)r4boecU>rtHpp
z*oDor;Cz2Z<<YPAu+LB9Kvu&#AVuGhK0uOEgw+QJ7@`{ck$4%!^`qn)3u{PLtdz`F
zIF7m+l1TK;j-4b5#i*OUu{apQ51!~`A+C!83lF|7F&wiVJKN2|B(8Qt3(JZ@B?d_+
zEiHqN;^E9QD!}C#E9_tw?m}^;n$lU4oQMy8tTXXR)z%}-Sjmuoj^j(JHTUoF>*8Cq
z12Ai{%+B=U^Qc?-Ese8J@Q3tfoJoJA{~3Q={8b9G>aYL)`uNDV<Kk0fPEr_&G3hR(
z7G`!Z)=KT%?$kDSq_&!gSQoPq>+j}TwB&UoO0!sK<u}YppatIWse1>Yn($2J6jh<>
zVm8Vlt7NPk00u(7%d%NKllpU(eaVaZY8IM(JulS})OX-so_zupz9<yf<M?;vvy4*J
zSU4u+tiF!;CAyY@TaZ!K(I8ypVac@egK!3aa;>iScGe5G2bO}d1lJu8QG{iU%wwdP
z8Xdz38yIVJ0Qxn2pm)Q@74*?vaavP^zt+fSu$y7}9N#@pTK>DwZTa&tq7mAGP>vwY
zfD=umshWwY*2|$7RD{b#klda(g8t4UZ!Le13BO_@!3iwG0Fxmf5FT77Sk(y5U<=d8
z3d4<#^={8IURzyA{&fTyN@cbDYGvVN{@qx%bpz>gzhH>Ve#P<n!K(|jj^+9i`14iy
zl-IvMvXYA1s7Gd@THm(97bJ2JUTZDLO2a9)Jl7iBlgAS5<@S;+Id<?rrECWapd?tb
zFS(UQeY%{~QL=?e7ZNOSg(fa^rs=5Bwf%)Mx_5jt6Uh3$SCBf7*%ij*nS~KQCW$YE
z^lv&x4gP7$=N~X;(6D>AQVgO!!rBTXM1g>qFwjRr;$58nmo#b+m`KPVyjBokhqenr
z$YLA9KZNw#-2eeR5ZZVHAcUW?TQebqhpk}YxkM142vHm%ab8GYhywyXd=0`!HAk?m
zwf03EkP1|+jbNiAeMtob(eUa41nud|NqE@0D-smE9p?`arw8J+XP80TLx{(D*t#oD
z*e~r!S31&L35XOj0VAcw4jK$OdDz;D)Z%2V5ypY4Y~u8{N#KNET7wrQ<YZghz0Y25
z?|UWv)(`*RZDAj`H^PBm@SSj{;Xt^T;ep%Qt^)~g`Y2@~aRZ?C!Op0GIK=G+;u<%c
Zzt)>zX^O1a1YF>W!{}2uVH*D5{xANHJ=6dI

literal 0
HcmV?d00001

diff --git a/tests/example_datalake/weather/Weather.parquet b/tests/example_datalake/weather/Weather.parquet
new file mode 100644
index 0000000000000000000000000000000000000000..a31a6f500842047c88b8f8686622b84f5c348aed
GIT binary patch
literal 21006
zcmeI4e|#Kuo$$Z2nc2)FJLycDO=n9QH>C-iw%g7$O}i;2-B!wNHQ{zaWy@(@5b|u5
z$SyzbR?fqH5H%=0Hi(!iax0>@a-fMt4IZb_Q=a84KIw@Xd{A?UHF%1tAO??zd*0tk
zTUzn%b+6~|%d4|9^PTVa^Zoq(e7?V$-gS`|7U5^(;d1MS@RJ(P!EjKB-?g<j2qB)-
z6rm|<G^sU)#D?Usri9ifKXyn_#5&UobtE4<!lPqaTu~7<b<t@?^=Pt}W^2qeZ<bg~
zX^d;F>2gns^=4L_6Lz#eQF}MhXd{<PwH`CaXIE_8?h1fA6gYNNtlw@4agLd`vlM1U
z+(@c}F4a84QOmBOt74-ORgc60e2!V=a>dzZv|se(#3r7*fZSnPb`5YAt<&nUUK$O9
zoac&eGe&J)Y%ojqIKT96M(ss!mX0?W331q-w{v2HQMDJsy70`3h?`N<Qjcvhz$zY7
zg&QvK`BQNWIK$qkJ#Jgna_KphiQ03vmC;3ykyVG+nR8Hd%r1+~P-WSb_=Fnqj77C~
zvsv;4JSh(eaU_$=OnalEGaTDn^QPfm2?DC18TGO}6?jUTIiCUc?7q3Z3Fy^}mCTe~
z%cO*Dmc?rM4y%(?K9b4P$Ps6UYeoV3YZ=!rc?EmMj;h_su6Z$R*E|c7)3yV1^Y*ko
zKQt<O?WkR~X8@NI?dG_!%oI$@i4Y77bG65X`ozv#>cZe<r5PKW5@#WqHm-I!t&c6h
zg*F<6xgu~k3=Xd`Q(no|MT1|nicEB&a<wA;mT+osmhRH3nEq^8ed%jGdC_7!W>THo
ziEMxQHDiGed+Hg-UJ#Gc;32NXxYW0FW==d0c*U%!PkhZti{;?-nsC)9sM@qKp?-I#
zT}4z4rmjA>(*Qa3yI(UV?6g=B7vhEOB>}9M>>(+BYUb=jW(tnw!M2h~&{YCTRwLU^
zvrwGn$>Mh*o)!YthB9y7%Lyx<;P(mYI^vh+jCcmfQWBB)6fD!lqFEEq#mB`QdJ%@5
ztN8X}+*0-Fo)Wz$#82Z@p~K%sK0Z&Sm!v#Yb-HJUHdUcf<=-g&C9q!NdLB)0Fh|94
zL=}Kq1zco53)B<nrkLLA@L@{4NQGzOGa?ALf&kFXY;jQp;xRiVUN#rS3hMmSEc6M)
z6v~XFFb{DB;H!w|GHGGL*XO~jnGVBJIAZT;W>)-kyRHaxq$YkDuRvT>Gy&@&5R#Ia
zGb>|xG=`G+_}J7~VQd;k)rwMXE)esOGtoCsKWpOd<V;6Z7t7*0_LCCFA-^?V>JUv{
z4An{@1U=*M<c`h4v>N6)Tbzfof_TBqPnM6@Y!^k39Z!kxULVa&qe9EgSVz5yTgfhW
zR1G}PD59u|)^O}Vx>!G6#pIj85}2^F1m;pP(|$cv_vqZ(9(<epizSzQ;>3zGed3N2
zKJl?5{0%0O!-}FF+ivKg;cZF$WOUO~`-p2ep<}M^1~=28XXtvlH>su6BU^dxH!OAV
zTr@@(1H4Kl4<*BvcC{)74C$2|aX6wYf1?i%_Zl&^yxB<FQ|j;z>K)q-zFR32JHj!e
zZqBR2Tkt5ZNEohK-i}i|(r4<ZZNHf{^Xl+<__IXZ5@j=?4sJ0E_M$isrRg(L>ft_f
zLToWgs^~ML@se6TkA5X+AnGC!PIeXSX>r)Bse?PHerPAIx4aAIIh`~dq-ya7GTRVU
zzr^xfs0!^e^6GO*Ol~kf9<F1;$95T6@q}%`@*^nRG1z_xYmD^su*FEIhkA{?I2<1r
z$GkbJ4=0SWdgNR)Hk1`dyjii+Obx}vbF{d2S2)oX1IRodqVbA)2v*t!RH`>p*;4}Y
z1U6R{VqfCQWzw(e@v7R}Z;Y#v?Qo=SI~m8Ut49(>3=FCwV$Xwnd0%-?T^x!-q-R9M
z@Q5Xj3}wB97_?{1tesGg>;&$4_|tS>KAsi(hIDawWJ0|)X}Eo}@x|hV=-n6VaWdmx
zf#5JLdd*ZkPcSGG2olArmo4V-`3ZZ$){7-NB%Fj}UDIONBx>~y&5xuB3t78jkD95z
zsiARfxI)~i+77;^*T9cF5K|9thNFkJ7YN8hi=vm{K?GW)TFOqym_Yo{J%0C2Niq;l
zJfR+TjX5DEE5e1YLw3wu5F%3QiBh{4+9291JTQ;1N{bktvUh`#3uiMGTel}5WE>SJ
zBi%CWj(Bx*+Kz(R#AFWVFslx4>JjRZ4Vc%)t-9#b#inrSeYzNYtga5PM~gPbg^6CR
zGiKC7=kOjkbf}ElX#(ITw0QU&BPWg!(l?-sJ&14}0_h3o4%8{p;|_5ZmW>nL5`0R@
zC`WEklGQyOf-M447OyNlb5@1{$OGRYgptYHQ}ohB`?BZ`TL<Pb`fi*?4CP<IN0S}!
z6@}QB-do|V4)i*VL<R$k0&FUFp74~!E66~avrG19T*k^Y$w1mG+tJLZJ(Ur*L&P2|
zX1y8MRi(zDR~o6JT2bWU(A_lMPMg+8a{I=65_X+9n<!3<En=CmgJp5};G!7LR5R(3
ziaNN>D8anNFUAhmFq(OBc+4G}d92=1Grl+l8@8CW7p*<%FXqgtF<pp}>5o)8lE&l|
zG#{IsK3-mxGsK~>IoJ~U)r2_QQ8zl~3~{bGZs)|tp~@3t`9zZ_AD>xep}fBmYbs6g
zT<qBPWUv1>aKhKUte@%YPUU~5qRKQ6ABDs6J>F~aXT!myd5$h*E~q}blbl8oGV611
zii!Q?j63ySBCalex;rQEF;DC?s%n4Iwg%F|a4x9wBg=HL6>`Zi0HOREf43?;{U${S
zYj;%apAZ8IZACbq7BB3c5=IK|UBUC@;Vc;-^onq7ASZepv0=9(URK0c6mfZ3p!h4o
zQDXwbn?n$b;+fr!@?&7-$TzY=372feh!RZ+Lx^hut;+A4p|c*D^+=1#Ur-9%s0e%X
z&T`-a8Ya<%Q6LEY@}w~4ADI<*D`KxBemXKPB3!+fR|NHYETKM?6qgbp31%;6#Xwes
zm4Uos)J6MK*}%(+Pg14ml15A%n`qd(AX;{3l>uGZPcJd?%t%7C+%ryn)k*Fxi4}c0
z!@8gp1h$bNVy7QTiW?LWuHFz6eU>qI!IawLl1@ww&omgZ3!>mAo(toD-(PEh(>;q9
zh{mm;y%3-MOr_DNi0ArZM(Oy1cp~h84FBME$EYq=@2&?x^3fZn#S>Gqx3oBWC=2Ae
zXx?4&X{&dS>okCMS?r_o#JJ&Ldd_Ej)YjcoZRm;i7YyszygC4e{*dBf>yN7xiV|w}
zhY_ls)RtMjEB%3l-Yy3iqHVi_288+H#qzU{1b1DuZ%6wb-|A)8dL(9yl9fphV96W}
zY3igp6`AX~woFT-WDW^rn!*xPo*MAFFYeTSq7KXQ7PKkKo$(7v@gj8{<V<o1IE(UD
zGZz^*YQDw=aT)SSw(lv4m$uIea)%sk6GV$vTDF@>GM80IUb>j>?KsR19(qXL$H6kk
zr@D{f+OXrffL#OT>!D^1jqzW0Ri-m^Q38MqNVGmaN+unngO#9|fFLVUvque3$;50d
zgSsoj`kpVV&{6g(nJm653=nHOR8KL4Ft(=zASylz$xJm8Jx~DeSz&~s8T)HBN6C+(
zJ)@!nlZj;}GBN7Ilij*7T);|pL<eStSE604IAza*VhW_Ab_}%A8OzQh_eFTCQ&r}h
zX?Sh<sd$LtK@DxkX6;4lOTt$4WqVw2zBpf$bz>y33GCXXzT?d?7_f}#3u1zFPUj<{
zi<FG$SWM=&(%g+~W>MJW*e{Jli!plwaoA}i;ic{I%nXdO;lC1gu~-pyZmIF?*jX$~
z4_Eko5ge6p0^n*`x08lGIf0%CoQEAV3j4>g6gvGWDf*)bWOQ;?ybvZd7*pW>C|Wcw
zjLRALB<!h3*~r=?*nKs7dT%K*>P109b{)ek8UPY9olLSA-DknY=kPcM{LwStBel16
zqZ+9j<M<!P8;{IlY6?id6m}sbnz6)-VN5GBXILm-NvQFhor?fv--O{Fk9rlM$77_x
zY1)@X1E?Dl7dQ>L9-XmYwOEgop=H#rbu8-p7VW(4_S8gkSSN?9M;7rSEmWJ&Oms(e
zBWBm%wP+L~(}qPtotq>{>JSEjIzO34*-{+~`tj)GDBow%KFs21bYNWb5=ZC6T6ml~
zUYe}GST~{_Q~DTVX1jD;@30J{ndq1?>?Cbg#!Fbif*+Gt4^<*lJ+sGWJF*5rH{X$J
zTHA`8<ewvh(EYLSgZAkj<IYy6fsaf=D2@8ojlKN#Z``IdlEJh@Jw_zLb2n~P+VsT6
z%|@fx!j~;ZSl_bIQ(E+G8@Fleb#G(8riV6f><cL8lAN`OEt<|fLr&f&66Q+X-RP~3
zlO*NZ`#1LCDut`;H~%NC`;-=uum?oH(xPtOXk0;^zc&Z?T~C|M+NIh<VoUg5kx=@{
ze;du;lY+N^NJ6`h(DY&LJz{guGO^8Q)O$B>)y@{1jiT94Uh|^)chp=BoHv=f%!fo@
zcs+4yZ`W(}KI+}yb&J>*Uk8S3A#%00Ir3iPbLO+ui0crcodfLS{(Q;ip2Ow`?0@CU
zp7?JGqj!tmp0e@F?UM?m?UiKpead{J@Zzg&J+6rUp8F-26mRd@_SyDNh1aveTu*}e
zHnBBxUDw%=knH*ht$LNgu5U9wcq`WyNfP<WhlV1c;|^UXHpkoPu$w%<ji2xBfT$aW
zUIGei2>0!s<(nQkPi)<FdAt=^iLNL5o{fK^=g%PaGC10+b=j+jg5IM8y4Z76Bu1``
zw-;~PyH<GNM~!=JE4~czCc1ViT30&$c)Tcu7hVNw_lW+X_a3-kxZ1bu|6{jkUjn(8
z4-WQ!psSUyYsI#ny$1&vyGUezPG>*inPmIG>v^9A@z0MOxc+O}Uy3a~|5h9r`sALq
z<`qb0&Cpu0^_FvhRSrM&z8gN>^v3C~qUay{xHcjZdvDT0;Z>h*7yb4otv!BexW4gh
zaWE#f*z2_G4_+K!Z{B(EM)S|aR(sv2RrvG<(bwZ~|K8ByaEsWw_rscZ@L_ncweQ%$
z)rfAJvZCu{P22NP^}=0Bcu(x$Rpuq&a4pwy^V*Sj#NUMKUUcQ}wcT-pvfJaNeYXs1
zcgODpmz(2X-SacLdd7UL>(2NQ7`~}%xB1aG?)_E*Ejxz5x0>%auM%#LW4<1G&ZZ;`
zwO5Hg`}#w_eQYd#hj~%_;K=`ths@WHydJfFz4kynaQ&e@eemz>zVppryzhDKJMn9W
zR+{%daNf|*9(!u&F4Seq`z|luzvlzyyG_r$KzO&bYoB=69hwV%XJHnvgOpttnb(^0
zBS#;ykA6~P^wX2s`WJz&=i<vn|G@|1w|(Tb+FH^7*vEwXXb`pd@MkaWx?Nj4$@@n(
zYJd0Hv*SPT$B!QB<^2l$zj*uPJNH~?-+`9j)p3^o+4~N59(>pJADz6;_;-}#qP8}}
zICt`P;q7e%ht>4|z@^4(#paFQ(EGZLOCGyRZ2jUd9u2^gk?#G*mAf&co6*T<4>pLt
zy;sM!ZCvshn>TI^tKr9$@ZHK_cug3af4dvt_rgo0x7l;y9{kM37w=J8b$*mqMH3e*
zTI+@K<0a-g<7_<og?6L3MB64VQQ}&9$0Zm0Eib<K5+BSieA(kh_!o`7FSC{=RDYpX
zPWUn{AOeai0s*xlpawLqAXg(LYCsPtmTm+Zwa~&~Q$V3ap+-ZXIS>dmsX|o(p@2dA
zW}X^U*_sxVGy|iVCt&E!v@!xsK|Nro3Uv(HhO{>bQ@cv&%I=UX(sFuJpvBxy!4=vy
zQ9WP=meD+*y;+z_Oazr%RU@F>qnoPG-rj10tEMVna@0Tzz?+qNjOvXvFu_8pDXKCr
z6y-s!yul0zwNY*6V^CFotn2jrY`T$p8dzu)>rkTuq(Lipwu94C%39?mT?85xU3s=W
zV5!Z#nA)7H!yc2W%`nF52`b+|U)7*Rg)(aMye!bvwGjxHqKV)#s8p3pMX*aKZ%|xI
z1cJe4#bqeTH%;vfh(@iZS^?z|$E3tmHL7nAs-4z@fq;@!143(8+Bz>1s&<$1R08&b
zuHZKSB%$5Zxn21nFuHZb)fH<MYA_&z#@(bad9iHQ1)Zu0cHWwhR3Zx)5De(5K+Pr^
z!e0pthEr0_W|dZ{Aib^@#D0QmqK}`xEm}}>h)W@LORutA-Qw{zp#-t=kl3n()V|H~
z1w-o7QerbzHyi5^=VnT_@wQc4uJ&zHw({U|UC4*4)I_i50LG)vX6=L0=QzCV;OdZ#
z)NKjH*|K$;#HK$Xe-kcB`*c(IKI3$y{ereIa6)S#S1Je$ky;n@B`GzrkxR<8iC?LK
zA%xa~Y+87d8ltqWl^P+HoR{T#P_;B&2|9+axwe*yE$4%VOjZPzp`nJhW*ix#2nxSJ
zptMSr<FbG(Z6d@odPVIGDoXo)rzsGY2BkUe7)GE?c6+OGRjZ&50>5yJ!Gkn}rl1zo
zgGOt#5eO@(wo*$e<1rm<L-d5rXggwpw;=ssXWFgV)_@&w0ug>&fQ3l}R`H~0SGWfC
z44!q$L)t*6W7%-P)DlXEa%pGQ#Q^AIm3kJxLc6PKfm$P%!TVY2DiE^y)(+%Vfz^St
z_-63D3^ML=gT9Rffqqt?L%UgdUOAFz0t<_pM&LDpXrQg@O`#5~K>5v<6|m(jiW@;_
zRiN{mop)Fb;Mron-&)3}_O9)r74T4b%9U(uL~o^2F|{M2xvO31o#}R{#f}5EvRSB|
z8<e$cn*h~FZ!M~l6hZA$SfmCz18We`S)DIz;MNp4JD}nsw63Sxk-pjlR-NxwZV;OG
znO%%9wBLu8L2T#fuKnUQyUyQ0ugmFOGB&#8d+$5tdt*}nF1|$OUV9X+eaX*Wc*&9z
zMql?R5%uB*B_b}?BKn1R=N56HagNwSx`oG8Hkz$`IoIU_5MJ@X&l};F&+x#%S97O(
z;3ZuSYA^%Y2StO{biPz(+$Nu->Y*m8u_osG+CWG(rJPfG(4>NfI%&uU&k8p!sX~gr
zAq2^)Zo;f(K_#(PstYa{=c%+Z9=L(;0m%eadO{^7J&D#z^`K@61It%6%~BG$e@nS}
z3m6~*DJ|9HOPex~mL_I`uoRcYvor`zJ3k$u7wLE!QCbs!8RA>Bb`g?$&}yc)pz?+A
zsIr4)JOeRf5}1z5B7rp1kokTcd(nnN(4Z<G!}VXZmOc!8rNlGX`DW!!h#wCsUy~u}
z+mz?wR%=2U3PwSBkUkCN9_4afwSt{**R6mszN1~CY^L+hjjhrn(yePOC~p@Houe^0
z7y=ao7vFgg&<*WLpeS!rZWUHn0D_eZz<zGmati~4)7wR}b}PX|?X1CW?Ftd<TF3Oj
zo8eVc=SAo>d~6OhDLYgGRZW>oX=)G&1whY_g~%oJharE1R6Ep6DoumZtomVp4-tQb
z5i(Zj#B^-~U@xSKX>_Av&Du_JiShchub^n2R3_2{AB+t7^G5iqXDHnB>fj$JoQx_&
z(m6tUPzH196Qz^X(K`_J{iKv;69`N9MVLhGaCt}(^$Ro_10lj;$Y7#L*^cToXcs`K
zk~5ZLd26qb$-+`%fnw5E6M}0*&iKC@RWb#~kx>n)Yb~NltF+=o=}q|%UN>(s!-pz<
zvlX67{cW+Nn(Er)mUQ>J_M~#Yjsk0=qS@H4eMb2l5&yb&kP8A?V=e<_c8STzmWY64
zmnpv?t<g3sTOFBS;Ig~ch>*4%!7V3}9t-I~w5?rN)fVL@?KjG1IwHPk_ba+9BMM3c
zMx-g)Z%9y<NfpCwwe`5lH<W1r1XVL=+^CYm+z7}vWe1`AE5w&3?M~$l?RY@iph@HQ
zJ)IWWfknpCpxvPqL}S+m<qMrpcmB09EX>YzYEUQ_>8h@hfeeaf#RArwmG5^B%AyCA
z7UfIi2r}i8b|(Xm^bwjW6>2mPK7t?HD1-aWSQs}s-6pn3rRa5u+nYht>nDnPp0ZkO
zBbVHawf8E`q|kke&D%;D@k81k)!RljB6W}UI(73_#a4TJwV=`C`tiB9-v`-;p54(D
zzH4c&_C#v=LG9gV=-HX6r5~a-y)}s9kf^o5OX16?L0Q!fT{0olw6>TGfHJ{C_l)f!
zWE#}ofPxrONiSD6J3%ywj7-Ze>4WlSz`c%81y^CUOw3xec7m=Eq?dMOor+@Jp)|=n
zQ!C(INFYm!6O-z`%vViAYr=67)3vWC9b%a>K@MiTU#o1839a-}_?94fON;h8<oo;9
zM&cuC|DbW9@q6VF0)C59+Co(sfu$pARBa^~!>(lLC0whD8<Qp`V;L@8Ti1DEYY>kH
zjIH=QOSyw^H;Cs{p0;FUZqjZf(`^X^_0BxX9K**wVl@-DR&-qy0|+k6AoMk8Q6*1~
zYH17jIU75`6q7=xDZbBa#jd64q+(byU>np{xb__sQb&XEau4I@UZ=|t{N~R03thXz
zSQV8dH;~4x=#0YFC!<YJMNXwEnrp2<NKM+f6@*t>m)<$P>jI%*B|(y0EzqXbT-l)v
zSJL=bpdoTMN9gp4l;5>QPiROhkw(}CqYY*>nZ0CIm6<L}tYV+VKtixK8WqbZZKO2M
zVo*#@|1qPZvrc3(1;?r^6Fm--J9#-Z$=zk{e|DfOnA}S+IVg8qu#(PB1D$GRt{lIK
z{kp;;3lmQEC@U#ZTduLW=7gMUqP$K6%bsA4ux@7uT)_)ndpW8)T+^8p6(@L}V3UGw
z7ii=#r&I!9mUrgV?9@P10BOS3WqVfR?RhV2R|n>WUEa@Xfo{*TXp^R`v!7+*{6Ixy
zfWlP7er65FL5sPzp%U;M(3odJSoV~*U3N@>3(G#yF{V11F6=TZ%r@)LCChbB$eOa#
zI$&7olaDp82F7x$M~W-QUJw_0boQ3Wo@xWkY>t95n@TKLsI&eD6~!2ZlJXfZ%_o{V
zfR+_vesK(vtG1pQ2XxMJY$cOpk~ht_InTAr0~U)?^cAI1R<>vE&s(r#nYuR(0y7M&
z9`zYhvh|~LnJm1D+DVVyC_o(ry)xuZ3=|Z*0&uHX<8>73)4&8-kYN4Bi$RG#z=WwK
z&WR_1D+L|%N-Q@Z57!d|HQ_Tb?MeL0l5hYxfRYuM#)iNe*R0qQ7hXQY7v__CnC6zk
zEWpJonAdo6ePLL3-jghn!p>!C^c4f=1g+-yO(7_Y_f%%WtI-bHn5B~ZVj-~oY}~N?
zTe68SnSb0S&X+ckmNsz_nm-^lTwH*z@8oS4Zw?cguVa#aE6*wMTE4`2N{AFs=Tc_}
z*Ljp!B1_4i@st;DG%YmDPKrI4&&3qg#BMA@vY6QeCeLePkatIH=eH_LAzv47F<o@8
z%G%{+w95ea&9rsxahRF)s$#F{dOC9^mRu;6(`|C;7t>70ZBj#knuQxtk(A5+aFV@6
zC}=FBqd9Y#5{kj%D4bnn?e$MgDf5(Pc@_BV!pSl^G4IWb*R$$5%UY){-pb;|ggxs?
zxlDsrG(#=uWOqR^$#QB*YH-eD&Dc&4lmvP>E&kLj49tm)>s5;-)-*PmiA>JRBf2S2
zlWOaTeJmjC2X6;))y1VCJMTpiXA}!X-=K9K)GA}xenyC#SsF;9Dd>Up9eF$I<<aPZ
zcms<nZv)J@WUFUorlC--(t-|Vmh_}$pqotE$gNpXbf@aoC(HKqz_{3N3EQ1?GP&aT
z<OI6p4ip5cgldU5nRS?wp3G;Y%~m`e_DLF(W2~u2*}&MCU8YWwhSO}Hm}03Q!53*I
z(|k$8_>`x6bCgN-Pl3i1JW6;@MtXx9Mwx&c(abEOn3;4l^O?FGg&WbaBqWU51&{Y)
zZLB($!c0nVDmyklR+@B*bIgsg{@{t?;-m|a5^GojOnodrmOPsG@O_yC{2!mJPEG)a
zO#)JU9_#X~hpt0sdf8f2^+vrKE;!06##;2Lhb;v8qh&DGy#gW!?!b%!(q;UEbSjIG
zpcm8L3=KtxYYZe6Z?<EmiRIEcU$WWu^-I=v!rVUC^2g0>wKTW2(%kldOM=Ve>gU>o
zFfD&}TW%$kt9k6sW9hCH{Nw^)8`ny%Rb1@9Vu=DB^3Cv1c`6f}EU3XcC{6P#bxUq=
zTQX7B*nE@5j4@~3=Y$M^ayNhrPo&F`8|~f%Px9E6HIT=r%Pl&H#AOxU@p4$!lIh6}
zY|CMp^fxVhiQyA0)`!;cJB2;Pyejt7jybdT=1tjkl%<4!NMLt5Mz6D2#72fpGLu6%
zx;>wfE<pN5A|S3I2RUq6MDP`F7M@2l35-7>1&w;mAf9rjT9krMVi(z><&|+O(nm_C
z9R*H`UgZYClpm~I>QrIwGGaENfhF&9ri{{+GWx(oK%CDq>svq!kCG_^k~rrP*fRwP
zWLXUzVtFlt5@eEyzsmP<FOdOc#>GX}rL5pytf&vvaeB}MU&h=_3Q&5cj)|}UhKf$x
zv9UC(YHOf`&4@>xObOje52OeU?7r~IY^g&9yzyd!?K!Vy2ZKJD_VTEt4%Qb)`o(@+
zon0v|*b`%QTo=NbTtw>Unxqt7lxvEvvfijYU$g+9qOr7z5`Lt799zUSJNROj_izft
zw_?rCjm;6)FJXaiiKXeWnm3E$C+IrC_RNd6=LF_RoW-;%u%-(C6W)YZ$mEHbF?Fm^
zbTab@ecqlLlUqloClMtLU;|!Tk_*QO5)Rx$+>;AlVQl_5G#thLB$E*IyeB5-@ia3q
zDv52&(5XZ48gr&YZ(?27I+`rjGL^A1qABn(hjlJ^Q(kh+Lhhp;t`+iUj=Odqu+x4>
z!8aa_wVP)c<}dzWr|-#KZT{Z3AKjMhRg}=DZc8%06Star=&IY~J~#2tsK?8uzBW){
zv7SG@VxVTas3bMHg3101RE=GT>ObAa=8B^%$Nz6y9A@j*Ki+0!MIF_DoLZma{t@mI
z7}C#(anEu85%+oSPjJn0J<2sjz0U*SJ!Vzh5Q!?kQ-{A#@q<+T62*720Qw1@XV_FW
z&-1UPt%!T6QQ_+muBRhOtsuUNV*f4O$z8~|vRwWd+Q{|Y7b*KE${u0hT4%ZT+gwlZ
z?W<f8$|Kyr&i!ug*Kxmx`#-Q&E=l-~?=ap?NshgD2{B38&0LRA?+EbTXV%330QScz
z`yOq62`Rte8ynojH@Vl?Gf=0;C~NAHo*&TWDD}TZ{lf(Kah#WfLg&Q0Sr`8+THMdq
zX%>m^j3h7H7M>OV0;_+=H+2Ljhk|~R_q(Zc6FvPU_xG^IOArwE%Pp=C)9o=T8zZAa
z8>zuAR}EGU%!_{q;xDNkptlBEHkcDEEJrEJil5W#^YHa~z9|5Z*Kb+>UlgD7x#ftL
z;_MHh_4l~O_)<YGa+AUo-w#ptX(0VOsq#!*7q|2Lj9F0CN>3F}UK7jWj_=XsAY{=@
zeIohEm1^&I>Gv3YhRk`)G{l?SG1|uVt^&A48I#DJtV!{I&1vxy8vYHk--n)E!}T=p
z!px2(;BpKo39z-qk7Xzy%Zh&`yTlZsB1<?4pi+uC;Z2Cg;PEw3{a)&RhwIn)sU)E#
ziEq!bKhzSzA$fQ3t}N)Y9b!q7oOn`tRkrs)#RQ1C#R6f#mAgIUK4E_d^}DzQs=9a}
z&TtZ%TS07@IgW>fs|onA2<goHNjbtNc0m=##rNW5y;LO@U<RY23K#C@twPY7Asp7^
zZWXjg>eL)ke-IgdD?X8#K3)^g0*M{D$LkoBb#&n$5?4CnFU*`LH^42BF*%tU(sMDr
z8RVPm$my6sROGon4=bNRd~Rl;BgHlXI48GVW<QbqS#Gjy&#^r>C%y<VpQhj6o1>YO
zXp2uHA6@)w+{G#q#aY45@XW*{o44atu`)hS_$ZCdpd;C$?xhLCCF-ZZt$K7Gc`d@W
z9Qsxl-)G<Mv@X5^b8p}pMVxi^T30*jy7)(syVsmQJ`N`=EJW_;Sws$1p+!c2=7>9>
z=OOI*$3)aRlKuwz^RU!9(_$+_$DEEsiLzzFVH~T2V<S+0ZnDkT5WgWa9cRPvSOv{V
zpd(fB8+7{LsL^E3b(9P*N4L}FL`O{*Vx$_Izir9$-FjPcX+Uvj_{<FF)Rs9M=#=kA
zWAD9fX-n|CZc8dFRZ)Ur(uMpAM|%7OI8iZNwAH~KI=(Oa2^iF=STkdx2bP@gXL$W<
zjG@M-`yw$W;jV+w4^aAL$a?}Mc^swvX2eq7st#j^q8`a=Q%Ksy>qW&CT-Q)pvUnQF
z-i0haPOY1{K1}(ysrMuRe#p0b(Xlb=-^}$0-~O344|AX3eiL`OJ(<m_;vj8jk>Ct%
zzJR9w9rsDvOp){C=pl+9OdyXKNGI`14#}7UHV!p)@io5R$8{agS;{Wteh>FiWLW_6
z6yLt;`}7<Ts=Pg7*1S1-D~ta{-A@6N;KY|CHjsEru4}>f;}3$-XJ~&H*Nt2oc$dQ^
zspNkS{EzegiHNhOD#n2%d-)a+=6v}}J|t-Ef`x-ma2O9-;vLZXE<C`TILxjpaT{Bi
zW?@tU#ZD1QEZ=n>mwQlgCr)unEJhMnN>&yK2C@t`u?q{o@-z^?5A^RLx)1UEL-2o=
z>xW?R_h!8~PoH`CFFp6i=-`8<GnSTSiI$hJyd;B0lvWj$o{6z3RjU~Dv`--Z3OsS)
zmyUg>k)-szuJ5ydPrjGMz3e3cL%FK#8cKMhm`ehoIpTVn#KE-8T`GWdqZl)Op(4J`
zKD^aaaO!@@_yL7a0dtNDzl=CvZ`?JZB>-6Q{r>~7;%av4*8o}rK$Pf|Rml+2q9M+1
zIT|lHCkq0Ywu+~5A2`{^a=r_ZQ%oV!Y`J?cj{(X&qD<x^x8aho`h+a7ljBEb0%w$#
zE|YOrFjD_njItyQkhG;J$-S?PF{i|@<1)-k$C@TJ|2a$<i#wAklsJKtms|d3a0po-
z6-baqQ7*UWjOpUH+tV!5;tc2D_%YCuDaePoz6^*_P`MqZHL^KFo{TZMeoom}09c{3
zFZ1mY+C9i!<{YnsRLm1^_s{X@QO8$@uW@3*VJ-$KcR2baJ2JucC^USEhIhlf1=E6!
zK@K}C5R#%^E<>c;9uvhp8q^qfiez@!Yy}rmfw?pOj>Xpu#Yj894lbW3)vSY+BeO3?
z;~&KjPV2|nUkpcNTC~9RFqD4+q(4fvDax;7KizkDZlV8Xh<}=I|46;txIPbVcw-ba
zS(F%-#Am5_KXQ7zsdtnZYfloLhsvaXIX|12hEw07;g29p3j1fK{tuP+E#ea%H%B4u
z1v>aH)E9KzMV3S^dNfI4F81{kuJV?X?)BlOGu`XSIm|{mfYjswk}YpUbDcqej;I~j
zCKG8H=N&eo?sw#rrkrbIWJW5@kb7W4j%#D$tFB<8Ai-csrxqhNoebI{o&&0GTTB=N
zXOwn|oK=h23d!~;-x7YN?($KwqXSd2R*pgj8L~Z>zUyxlg*#YK#o|}aV#zr+N*L}_
z!!ME8P)knJMHx~=J$FCzmkN^y`rQep?&OE0>|_Z8mob6DNMDB_pfQ~)JUW$=ZYepn
zD!bGn+3z<`j}pNN3ZoJbgHdKu7+~5lIZG;WW7q`blmsTH<C46>L>l=-oIs2M26f)F
zobGe^Ch4YrrXZQ(^0h#xC5fnfVZ2D?37#B@4Pz%T<UPvdO4Oegl!F$3qEON;CtPxj
z{d_{1P?nuA7?Ny|2)h2v#S*LpaDXnWGW7v<i?(|sxW{CPB83Q^S$-wQVoYI3QhdsJ
zkQ5hAQegRz6W~t?d{6ENf}A?`<_3gvf-`cadY+1sdnZ_`pcOS)#JEu6A?J9JnXT-v
zN;KGY>(9F1-25MFtg;NnkZsx4ygI~yEU0K~VcZ=R479?sfR#-O!f6IFsuGru7938)
zB}N$(>dJYtQ1YZ;=g>YWh7_NoaK0pw-;c&mOVP-AZe7mA%9e8UEN4s|W+VqJsZ&zq
zmd`Q7b2lvDw8j3spxJ^XZd5S0Clz9zOY&8YH4}at+1A%uuw;ZPSzg``fC(C5K1|e6
zd6e>mZ$p@xSCg1gDj7QOKacY)(O6)#8w1b!5}sKaqGHU>`5Gmm$X0p3B@-IZ<m|Tu
z@?G#hMOk$Kp42-zJuFen@@s)Cq5~^w`Y9<_*$INm0oT`}>Ojdi>;yfQ;Lm~&A^`wU
zl_nOGwk^RjVE{)whFL(CS_-XmlqQzkN{o4sv_0$hEvF`B6KU>CER!=zOVjrfaGH*y
zeodc=erILW5a5flCn-&5i5CU9&1A7$yila7Nz;wOfGi4#IiZ&nO3^Bwgq-qw9K~-z
zGa5Sz@Ao5&i6tLmdH!@Kq%mDkhX=knNNOdSo_xqNp^=pc$eG|=yIjMRe@j~Zxj#4s
zchV2bQz7~WIZvRMJq{gk6xRxg_5QIpnI$r@#>RHK4Q=o@`!nOlSs;RxOK9Mnl6shl
zNOm*H{o$6{yM<t}h0{SiB$;cs*u<F<Wy1XiQiBP9TCi6hdeb*Aox9^ulz(a~Tp{9=
zISMu|4n_3NmAWYR8JHPINL_WX*O*cdt>;+U@FsT8>&kmLW#WN{OV{%Bl88hct>7Pm
z<G>sTiJ2zl_{EVJow861mV=w+@iwNg*mKB<8xT82h}{;?a<Z<>u`E|1usR%*O4=@)
zFO%xw1nICm(<6|0-mXA##G8mjd!lmY)t~K*a~7pHUKPSia_Ws9<f);A*xDmFw#x}W
zGsStWGUqT0@-z|8oIjEs4{=g!J+rv-+Q7M*UWxA}9yk<Tuw(smdpVP3Cir^HcH?jY
z*;0XgDaCKDU*{-N48gE?!%SbaIE^;o#!daN(pUak^fHwo50;goHDXqwwJwH-m@oE{
z9Hu+Mj&E^zBr3<p>Y;VycH&@xff3Y!T!OP#vkc5;#F}`4!LcQ}jhx!cF>zk9j9eW)
zlo;8{bGu8^&C^VfSCFn8HmAMxp~YL~#}+}4W8j%+MrX|3MeQCCk!Qr1StZxWGRa$I
zy04utatfG3#@+%wBp7zfv`!~!jM)oP?-(h{&F2>V#W*mLpru32k~~IX*BHl?=u6Hr
zv>>1;@K%yxPx-CnArnr7Qd_c*83-=NKhdz9(f2&_Hs_FXuH`zLT8u0uY(~jz!DiH+
zVRXC-tk+P^i3ilkVy2g<#JzwZ+Q7jkJ9AkMv`AO;gy(6nN@S8`G&%4n`+b>Gae$am
zU)uR-x<9*jT772cE$qm`d{$v2%fMMP9rgL0w@jln66uC`#V1)Fs0dNT<iN@cJ8wyo
zW{#5jmFT-hTbFk7z(5-3SR~rOpt&&%MigkRgGLj^v>b-AI1I5Ek|f5P$`pXsBS+kN
zCPg}U7W33;WIBx;^nK-?RB`5A6Ft?jQM)|0K%$Um)^t=v!dWAgDP(lII0sEHKQJo}
zGf%LIk$iicBRtp_JvpngMn_iX*vzcKH(YC`+7WA-oVIh_b-gFe2&|hk2~)<Zc|*mI
zlo`(VFq$cNsj=ze;#mFQq8RK*>K$oaoWt?s<fJ@vedMt@j`kcGlan`zquDY2f$SQg
zcT6`O&mPUM-Ly2KKeFw_i2fJ<fvc0p-1Kd7W>h`g&ly;Jl=N!;xwwr<gV}#v-=LQy
zw(FZtx+hnjv32|vj_n+Ejhu_TIN+-e4{*pOC(eWHLpyLVy*rUq5?lc!eSwatp*mZ6
z7(CZVVqPpV$rHOQ8{m=XeH)csB-oFM9qSDzwI8Tu|J1JGaMm+#&HxzcNeIJ$vhy@c
zs#H&^5qbW1i&5tMCH|jPjU)oz;h)3>C`XOevTR0&u6j(4oO^Mz!{_3p2jh9Qdlx<+
z5>Ik27C|22^B}@M#*xh<+xa5@BZNULV8P2nOi4}3^TI3;WI5zq;KXSe&r#mS(PR!1
z#tZ79&9JA>Obn&e-mN`VahR~o9{Ri(9Ez!j2Z$)4p%_A+^@sW#$t6}z4;3&9htr-@
z^1yQ%v__dVt;mzgoT{A_z1y7t42&}}f%VfPx+G|hHVF~gm)e7?PxQbRjw|EmaH)~B
z5sS~kjwFtMB3y<ga)jR>PF(gAy|<V3*<x9oi#I=J*7~FXQ|i8?k-#szG}{;Fe?}M*
z`07z{B+f~|p@r+E7g>)fc}CWQTNzQ5;Vy;`Cl7(e<04YDimb{H&2V0p4~GucM7hZS
zF;L7B9bz0N?PU?AObo%vjpXp<<K*v-SK>b_7?z88o8r}j4irmPaFQ1?4#5`A9;=63
z*nX%pE|<4ba&cH5EyJ4flZ5A<IZ>XBanOQ!*0?JUA1na6M3<bNvXk)=G%Z5<YO~7O
z-7@gAATkBc>y3)ExEv2I-J~-*AIr$T&J}$l>oKG#i{3n)R%E@R{4L8BHk{r$@$66q
z;vFO@rAcmzcR6CGU$mZ)WhGEdV#)FpTpq_N^EbKp#R`ZQ<IaMXh=r|xxthqmmaj2S
zp8d^(X4VfSI8NV<NLMT)8?GZh6R!Kc$#q21kj%JTGL!Dvf2;93fy-vikQLM@!|_f|
zILpPd1b%Kpy8fd4KP(EQhZDFr={sENB!Q5_rAtr9LNhs2-J22XP_-%<!3MLC5%f-$
z>eV^mM$*<%Ff!zExNiAj%9}c>kHr8nIHKbPb8Di8v^Y^7n`Xr|T`V6hV|S9LOf>Od
zE*#omrbZSf#|gCA<D_FuM2@7w<CD&>YW#Nq$W+dY^^WC4Jf1UCUo6{|2gb$V1Jk0n
zyFjF$oPVGuj{Rx|vBn;&iNRmR5Wj_z4w8pgkJpapDe1NA@-%S&(lq6v9Z9yetqOMx
za-&Dn^|v=(Eq4#?yYgD{!IuKz`vU$b=fv)_uPUh%dy4`AhA0fk*`OORb%%XWJhLm1
zomdRjHOrDa&^k;<ZtPQ9*=`?IHc+dDw~)4l?TJy%im^wW_f^zfV}=qyQkr;Y&WJs<
z0nJsiilbboB-!EpZpCug!Ospc_Rnu&N50=*NVYtYxW4cQN19JhT-6Yn&#B|gA&xV1
z@<BauoY`C!{_o?=|9zZ!={WO#jx(QW6DO=;$uzKu#X$I;Gi>5vC3(^&bZjEPRz=?;
z&`nN_NQ*#QeT(4Tw+JlcltoZmWuq(>A$*Gv%Xwc#O)NsWBG$y4#ak=8eP3k{d~>il
z?13lQTZn6|5)MROTG>Y;cg6K@d&d=*zxCR;<*yvMEWAO4o4Nu{<IsV3zTwJ|!pXPG
zO0T@>7hQJXox_)1b=A_x<~@IYS>ftyF1zl))$bJH5RLVVuYc#Y`2+8~vWxMeENH&u
zz&o$_lk2a&?)(GSoGdd>mR(%9^2#etmNv;!YV}_>@`pveg;PZ#S<7#CqMk}8uN2Cf
zYmt!bId%QWfh!JN_byrS56e!}lk_&HuetKtYp=iNO6r{;>tqSFmSE|xz3S@guQ(0R
zQo(6Z8YPoXLGa)F){+N?<k}mqzT&cXNy2;{U$pn)*S~dWXo*LmrSBtGUvtgXe?gVD
zC$&g><fXQ5(H?G!ghk|(Ou_-awcWX~t=8JD?{J8L{2kkpbjVHQUwFDr#QsPr4*PUq
zOCmi5Y<5NWMC&PNyMX4y9qvfJ0`2tDGoYPPiBsS{V|0(kPJw$Z;Ar6gy#ns^Qa-(c
z-03QH3gXjN_vbtyF8zNz>w&oR^yp3r@ztd#AclP2ol?mqaF55@p0vAf-@U^LT)4|o
zTp%nxoNCl1tjHO9yVUU6=C<z`-M7B6``L@zod!+>ILe+j(YEH~^O^0>)bS+<KWu5c
zFVy|QTe}~AOS|8D!0QD<>g4m85Kgm)rRIMfYJ1k`uDqlB*n$570w<fJg-gwE3boy1
zbpPhM?#HkFFEoF}q)_T508fS5KG)R!jT^gPc=r<el6h?#Pw?>s@~Y4CS6ZLyUMg*<
z``!;I$Z-pm<=>f_@#<2lNX=M+dAdC>Aq2=Do83n~EJ41_2Pi?VJ@F(}<JF~q9OUU(
zexarNzE4V!xl<s`(?Gtul#i$B?@8Zrifv$dd${|_&r6X0UYU)RlP0nDHs8WtUHZpC
zo{r^L!`;t*^AyOn5~Odm-KT*(qx1yGC0?HLXQvqXbW`{JKa}uJ8ta*|d3EU@fp<E7
z_cwP}e)j(X?}WcQ;Z0AW_x%;!4=+e?zMDIofZQdsf5>+MuP!}<gD2hbDR8&9cHe$;
z0B}?jBKeAQYxM>4>QYLij6)IMIlSV~mmtnIw0*Fl`y1nd?t8}r7#GPgR&h1fp`Lm<
z0pSFFC;a~@gzh%FKlgEokT1kzr@P1h)M=hT=!^)m1oZKSwwoHde{pZ1`^dfj2~KV0
a*&W1`Zia@z^GOHJ-z{DPSJM1XkpB;D<R^{*

literal 0
HcmV?d00001

diff --git a/tests/local_config.py b/tests/local_config.py
new file mode 100644
index 0000000..8466200
--- /dev/null
+++ b/tests/local_config.py
@@ -0,0 +1,11 @@
+# This file contains secrets used by the tests
+
+from mara_db import dbs
+
+# supported placeholders
+#   host='DOCKER_IP' will be replaced with the ip address given from pytest-docker
+#   port=-1 will be replaced with the ip address given from pytest-docker
+
+POSTGRES_DB = dbs.PostgreSQLDB(host='DOCKER_IP', port=-1, user="mara", password="mara", database="mara")
+MSSQL_DB = dbs.SQLServerDB(host='DOCKER_IP', port=-1, user='sa', password='YourStrong@Passw0rd', database='master')
+DATABRICKS_DB = None #dbs.DatabricksDB(host='DBSQLCLI_HOST_NAME', http_path='DBSQLCLI_HTTP_PATH', access_token='DBSQLCLI_ACCESS_TOKEN')
diff --git a/tests/local_config.py.example b/tests/local_config.py.example
new file mode 100644
index 0000000..a4e9523
--- /dev/null
+++ b/tests/local_config.py.example
@@ -0,0 +1,11 @@
+# This file contains secrets used by the tests
+
+from mara_db import dbs
+
+# supported placeholders
+#   host='DOCKER_IP' will be replaced with the ip address given from pytest-docker
+#   port=-1 will be replaced with the ip address given from pytest-docker
+
+POSTGRES_DB = dbs.PostgreSQLDB(host='DOCKER_IP', port=-1, user="mara", password="mara", database="mara")
+MSSQL_DB = None # dbs.SQLServerDB(host='DOCKER_IP', port=-1, user='sa', password='YourStrong@Passw0rd', database='master')
+DATABRICKS_DB = None #dbs.DatabricksDB(host='DBSQLCLI_HOST_NAME', http_path='DBSQLCLI_HTTP_PATH', access_token='DBSQLCLI_ACCESS_TOKEN')
diff --git a/tests/mssql/__init__.py b/tests/mssql/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/tests/postgres/__init__.py b/tests/postgres/__init__.py
new file mode 100644
index 0000000..e69de29