From c65aa2400179a12d3771a6d2e042c859da4168c2 Mon Sep 17 00:00:00 2001
From: Dan Helfman <witten@torsion.org>
Date: Sat, 23 Nov 2024 10:50:58 -0800
Subject: [PATCH] Add test coverage for ZFS hook (#261).

---
 README.md                         |   1 +
 borgmatic/hooks/zfs.py            |  58 +++---
 docs/static/openzfs.png           | Bin 0 -> 16007 bytes
 pyproject.toml                    |   2 +-
 tests/unit/actions/test_create.py |  46 ++++-
 tests/unit/config/test_paths.py   |  30 +++
 tests/unit/hooks/test_zfs.py      | 326 ++++++++++++++++++++++++++++++
 7 files changed, 430 insertions(+), 33 deletions(-)
 create mode 100644 docs/static/openzfs.png
 create mode 100644 tests/unit/hooks/test_zfs.py

diff --git a/README.md b/README.md
index 01151e70..63eea8af 100644
--- a/README.md
+++ b/README.md
@@ -61,6 +61,7 @@ borgmatic is powered by [Borg Backup](https://www.borgbackup.org/).
 <a href="https://mariadb.com/"><img src="docs/static/mariadb.png" alt="MariaDB" height="60px" style="margin-bottom:20px; margin-right:20px;"></a>
 <a href="https://www.mongodb.com/"><img src="docs/static/mongodb.png" alt="MongoDB" height="60px" style="margin-bottom:20px; margin-right:20px;"></a>
 <a href="https://sqlite.org/"><img src="docs/static/sqlite.png" alt="SQLite" height="60px" style="margin-bottom:20px; margin-right:20px;"></a>
+<a href="https://openzfs.org/"><img src="docs/static/openzfs.png" alt="OpenZFS" height="60px" style="margin-bottom:20px; margin-right:20px;"></a>
 <a href="https://healthchecks.io/"><img src="docs/static/healthchecks.png" alt="Healthchecks" height="60px" style="margin-bottom:20px; margin-right:20px;"></a>
 <a href="https://uptime.kuma.pet/"><img src="docs/static/uptimekuma.png" alt="Uptime Kuma" height="60px" style="margin-bottom:20px; margin-right:20px;"></a>
 <a href="https://cronitor.io/"><img src="docs/static/cronitor.png" alt="Cronitor" height="60px" style="margin-bottom:20px; margin-right:20px;"></a>
diff --git a/borgmatic/hooks/zfs.py b/borgmatic/hooks/zfs.py
index dfb13eb6..766a5a01 100644
--- a/borgmatic/hooks/zfs.py
+++ b/borgmatic/hooks/zfs.py
@@ -10,7 +10,7 @@ import borgmatic.execute
 logger = logging.getLogger(__name__)
 
 
-def use_streaming(hook_config, config, log_prefix):
+def use_streaming(hook_config, config, log_prefix):  # pragma: no cover
     '''
     Return whether dump streaming is used for this hook. (Spoiler: It isn't.)
     '''
@@ -26,7 +26,7 @@ def get_datasets_to_backup(zfs_command, source_directories):
     Given a ZFS command to run and a sequence of configured source directories, find the
     intersection between the current ZFS dataset mount points and the configured borgmatic source
     directories. The idea is that these are the requested datasets to snapshot. But also include any
-    datasets tagged with a borgmatic-specific user property whether or not they appear in source
+    datasets tagged with a borgmatic-specific user property, whether or not they appear in source
     directories.
 
     Return the result as a sequence of (dataset name, mount point) pairs.
@@ -44,12 +44,15 @@ def get_datasets_to_backup(zfs_command, source_directories):
     )
     source_directories_set = set(source_directories)
 
-    return tuple(
-        (dataset_name, mount_point)
-        for line in list_output.splitlines()
-        for (dataset_name, mount_point, user_property_value) in (line.rstrip().split('\t'),)
-        if mount_point in source_directories_set or user_property_value == 'auto'
-    )
+    try:
+        return tuple(
+            (dataset_name, mount_point)
+            for line in list_output.splitlines()
+            for (dataset_name, mount_point, user_property_value) in (line.rstrip().split('\t'),)
+            if mount_point in source_directories_set or user_property_value == 'auto'
+        )
+    except ValueError:
+        raise ValueError('Invalid {zfs_command} list output')
 
 
 def get_all_datasets(zfs_command):
@@ -69,14 +72,17 @@ def get_all_datasets(zfs_command):
         )
     )
 
-    return tuple(
-        (dataset_name, mount_point)
-        for line in list_output.splitlines()
-        for (dataset_name, mount_point) in (line.rstrip().split('\t'),)
-    )
+    try:
+        return tuple(
+            (dataset_name, mount_point)
+            for line in list_output.splitlines()
+            for (dataset_name, mount_point) in (line.rstrip().split('\t'),)
+        )
+    except ValueError:
+        raise ValueError('Invalid {zfs_command} list output')
 
 
-def snapshot_dataset(zfs_command, full_snapshot_name):
+def snapshot_dataset(zfs_command, full_snapshot_name):  # pragma: no cover
     '''
     Given a ZFS command to run and a snapshot name of the form "dataset@snapshot", create a new ZFS
     snapshot.
@@ -92,7 +98,7 @@ def snapshot_dataset(zfs_command, full_snapshot_name):
     )
 
 
-def mount_snapshot(mount_command, full_snapshot_name, snapshot_mount_path):
+def mount_snapshot(mount_command, full_snapshot_name, snapshot_mount_path):  # pragma: no cover
     '''
     Given a mount command to run, an existing snapshot name of the form "dataset@snapshot", and the
     path where the snapshot should be mounted, mount the snapshot (making any necessary directories
@@ -122,12 +128,12 @@ def dump_data_sources(
     '''
     Given a ZFS configuration dict, a configuration dict, a log prefix, the borgmatic runtime
     directory, the configured source directories, and whether this is a dry run, auto-detect and
-    snapshot any ZFS dataset mount points listed in the given source directories and also any
-    dataset with a borgmatic-specific user property. Also update those source directories, replacing
-    dataset mount points with corresponding snapshot directories. Use the log prefix in any log
-    entries.
+    snapshot any ZFS dataset mount points listed in the given source directories and any dataset
+    with a borgmatic-specific user property. Also update those source directories, replacing dataset
+    mount points with corresponding snapshot directories so they get stored in the Borg archive
+    instead of the dataset mount points. Use the log prefix in any log entries.
 
-    Return an empty sequence, since there are no ongoing dump processes.
+    Return an empty sequence, since there are no ongoing dump processes from this hook.
 
     If this is a dry run, then don't actually snapshot anything.
     '''
@@ -174,7 +180,7 @@ def dump_data_sources(
     return []
 
 
-def unmount_snapshot(umount_command, snapshot_mount_path):
+def unmount_snapshot(umount_command, snapshot_mount_path):  # pragma: no cover
     '''
     Given a umount command to run and the mount path of a snapshot, unmount it.
     '''
@@ -187,7 +193,7 @@ def unmount_snapshot(umount_command, snapshot_mount_path):
     )
 
 
-def destroy_snapshot(zfs_command, full_snapshot_name):
+def destroy_snapshot(zfs_command, full_snapshot_name):  # pragma: no cover
     '''
     Given a ZFS command to run and the name of a snapshot in the form "dataset@snapshot", destroy
     it.
@@ -246,7 +252,7 @@ def remove_data_source_dumps(hook_config, config, log_prefix, borgmatic_runtime_
 
     snapshots_glob = os.path.join(
         borgmatic.config.paths.replace_temporary_subdirectory_with_glob(
-            os.path.normpath(borgmatic_runtime_directory)
+            os.path.normpath(borgmatic_runtime_directory),
         ),
         'zfs_snapshots',
     )
@@ -263,7 +269,8 @@ def remove_data_source_dumps(hook_config, config, log_prefix, borgmatic_runtime_
         # we'll try again below. The point of doing it here is that we don't want to try to unmount
         # a non-mounted directory (which *will* fail), and probing for whether a directory is
         # mounted is tough to do in a cross-platform way.
-        shutil.rmtree(snapshots_directory, ignore_errors=True)
+        if not dry_run:
+            shutil.rmtree(snapshots_directory, ignore_errors=True)
 
         for _, mount_point in datasets:
             snapshot_mount_path = os.path.join(snapshots_directory, mount_point.lstrip(os.path.sep))
@@ -277,7 +284,8 @@ def remove_data_source_dumps(hook_config, config, log_prefix, borgmatic_runtime_
             if not dry_run:
                 unmount_snapshot(umount_command, snapshot_mount_path)
 
-        shutil.rmtree(snapshots_directory)
+        if not dry_run:
+            shutil.rmtree(snapshots_directory)
 
     # Destroy snapshots.
     full_snapshot_names = get_all_snapshots(zfs_command)
diff --git a/docs/static/openzfs.png b/docs/static/openzfs.png
new file mode 100644
index 0000000000000000000000000000000000000000..837ba3b96505ce96646b2fe1b58158e63e676f71
GIT binary patch
literal 16007
zcmb`u1#srfmL+IrW@ct)`?JejW@ct)w##gnnVFf{WoBk(W@ctj{qJ@6O!rR2Mr^Di
zB&Cin<UM(%lv1fMd0BCI7#tWNARu^22@%D=`_R9uHx$I*t#Ez83=j|)nT4>hyri%&
zk-VdwsfD!(5D*t~u*$aGx-yzTn4MxF27pLiJT!c;Mny@h6&I&!2tqQU=<+8<(dh~e
z*#Qq{SQ#$l`e{?SoR>c*#0Rk8Dk!1^A2B?Hq1WnDPotz#C{4MfgxARcA~D4!xXNz3
zt0AS*fcE3tIQKU9G4HYNx(L6X#h-L+mEXw~)mhVINeLwwiP<vYa}5hppbHhJvh;D|
zlPC<m=+9H<yZGTy<Ck$)U$Rf6-JTH}vtcB1J+|ohKG-jC3KI)fO;Tvxknb-R%@7;+
zcsKJLU?3GBDL$Df?z6*`{IbLV=;#@mbMz{x4hX)E6;sA$13gfzk%V0pTiiAh)3}DJ
zcmv1jUB(!PX6A21h76a73!Omq_spVJqZY)lE!rpLt}wvzp9j1fsan07R!IY2@Ryjk
zId2emLWPI2cpvAjV{tvbDzq(#EpV?{`x020cS{#$FFdTe*+=s8)DcpyWfwD)hC)og
zYt@&=6{C~5(h((#9fO_TpFZVjdg%_TM?st84Vq~aAfz$I-6fL;evp2E#;T4|@X0wI
zPS$*kJ1I3Q+v+l*wd!;Y1=vrPG+y195o(+Eq`pMLafCM4JnV6dpF^{!6uwoao@U5v
zE8y+fm}{{)n{yY=5Lg~7fDRtUBM7{8odre1rh*>v6A=+oSqyr^#j>Bgh4R@fi36Qt
z9DL*~BSFFa;|9zma&suwn;zUT`@=zz^_ZRX`3gn6!!`EZqjl;4rB&b$Lc@j&CR{Vr
z!dlLij0-5KUY=eAa2Q7$9(0;{AF9Xu4mlTP3?5neyAMGhs^1DztJgShlQCZ*>9ta{
z52SK4%xqehs6>#c<}RFb0wq>ffC~h^F^Kk;smm@aE9Vb~`>4$bn_-Sx+o7humzA12
z`VSjL5MF)H@Z`L)8`nN)cT#+QZQyxw_;b4*jhQvYwYq|$vseEaQi@){h`_{L>+VeX
zSN>O-ZK+-<=E63wWe_%RF_{mI5A7$F52X*|r*ycpMjOc|nNCty90NFa`*mjy`HEMK
zo&oA+xQ_XvRSr9)lI)n*0p?-iN5@A!A8svLs~$l@$wBAM1@zM-+$Vk~mNQI)rOY2M
z`dct8HbioWEQsYH<-wo|XAF(?oP=UUj*+322htK(?aagEaCe^Ua7u}=>j=4l;XPK6
z=Io9a-4}}5V$jF01XLy-o*f%HY4Q=)y(}IFRnZ3+=Zu+2onH{!2>Fr~u1g$a=xVDq
z<u%mM-eWB+I*a0==#y;d(}z?XZY`aC5d~yjfh5r<LR;@$qOO~8Hdk6Aq2GPH=c?vf
zrKmoaNRQn(YautX-bbwY5s;5<oqNXx5(f}*N<6jO@A#)udz;S9v+jP+D$|rAyo8)M
z-_@Krym}<x7_%n#01Y4qcWYc))W5e4XnP3_Cm<l$zhzidV4(C&EFd7z1Pf(#XLT8A
z9wR#&1_NU|LlXvf8~eY~KtO!%Jb#NeCe8*#?l#u8PCV}XB>$4&`CI-6W+Wl{mx!|!
zKZ&}GJdv=SqX`i^12Y2)i2w`{5fPuGu_=$Dh}eIq|2^U-F?V*h=V4@Yb8};GV`Z>&
zG-G7u=H_N(Vqs)qq5msE@8n_YY~W6B>qPo*BmZef#Kg(S(Zb%@!p@fHAG-#Ib}r8R
zBqaYh`mg2R^>nr{{okH!o&F=NzX3A-bB2+bfr;_IZ2wi|`v>JwS2S_5vv&E%z5pi+
z-@iov8~DE+{aZof|EBPNg8x%N&e6i;Z*2ea!2BN${!i>b<oOu?3Ge?1_g`H8Q_uf_
z|G&}jxAFdq@BhYvyMg`xlZ3z0Ji?A92F`Yl%64|v0z&`f0+FP(wTqLp<3A{ouo4Fm
zm5hOrg{`xllQ}gX<Ns9o|2qI<qyMVEy^Evuzp};Hh|$E_#O5!NPJd%y{_hQGY{cVi
z;cRX4pN#!GFaE`wkhSxFNB@&hYm0x<lgHY?){LLTo!;2Q)WF5snM6R&-o%zjQ%vb^
z?`mOV;OIdlZD(fp@3yhF`0u9vjsABJe2o9IGXM8>{WtpeA`yW3OXz=IZ~`!fL=#s)
zKpd8mB0|dUz?WIj-YScKzNfj}#(=04Ga*@WRWni1Yb{Gv&-s|twX`al)+mueRkhXy
z{8fFvv}|aF(H~WEYW~;=X20p${AtSj!^LE7(F-jhC{h((3OCyM4EKF)m*dqZBLM<6
zDiixTI*I+%v20h<`LyO$V+1Lrf9cGtmD`D7zvk6?zd3~=4?Ezc$hu-QG~lV|(bh@F
zYWiY-N6<g!1;%wDnSf_?Ysgz#ao?6j#7`xxWjj#lE)VFvgdU{f;u@eQk%uBPVXVYH
z(bSy?8}^b$Jp1|Mwc4tpda~#?Mjz*VbbQh-p?bp0$znbDz)*qoMDytS)vgKMyB8+l
z6LdU!l?IzLqe9T`skzKv>J`)r{?8|B(w9Ylzml4W&HSF8Uq*nxur^65Q!l`IVnskE
z`yQ84#km;$<>M9HJcJ;YT%yj%VSJpe^K`wp^w32q2cOwcq@$~=OJ7)8s3$LP@dn&n
zQK0^5%UyDGd862cV3IU#KY=GOp6qN`QIwi-bHm)ks2_*mbF~|0R0xLDX+e6SasZ#t
zabq^wM(>E-&aYt2ux>QUJGn$I7It`==w^O0O})N!qG3Ko=~JtUSUBKgY9UKT5y@V;
z%4fbY_*$Kk=eBU)j1@<!DWC4ln8QeZ2dLWh0A-(Ww~|yg5w}~Sz-N}?j`9=Xer1WJ
zaYi$^C{P5eu5?|pqfJGakx?bIRDj;0?X9>V<b2Ni{b_SuInfuC!;~z*);}SYMr6Pc
zs;ZcI9g5n3rwP^RM)h;;C4<j<-2v}Y0`^;`{s~>p0tsi$T9E@v?6(bVKSk1H5(vha
zj{c?RNh-4>>TioL3jg+9QK6n$MaGeMweybkWTYxPAPBHPYqWKjZ6$G5Fb+Qj`45lN
zfj!q9FG8YC(^fb4&G0wR&~J$G=Ovu)4@IP<ut7Wq0)s8H>@qY?5HQ4q68kj05DcU}
zJNqJ*7ORo=O_s)L^)DqbWLm1T?QWIUdtsMhAA?>4%N7sm1Dqe7S))1E5ZQVe_EO{Y
zfR}hEX+%{Ls0R6oFb)6XP55oDnfs~)Z_f96RJq?RD6T#|f@p3{hXXNBoddgFDL!bv
zCd3H)1x~d-(_Z+oJ_6@#@Dw*TKbHz+2#Vpla{N!ei&<X$zg2+gMJn%@e*c-#la@5D
zht!Pz*0}ScuYnu0y03<m-fuR{-1hcq;u%mCN+7_O)6CBB=rA}+q;BmXpdnP@<-?GR
zeq@=nfYJjYR<)+0ep^~c{8EQ0a-$Vn{F-sh47H9)i?yM=g#_+(OIiNBP$^R2Hoa&D
znmNWMQ`}?o8?WQPHXApU{Y8^99CcVQl!M?9L!{l1AdwuuObX9hvXyoJ&G->>{JHG0
zE!{HLGsyt`R@J?`_<n6iF|kb}zVroY(z5Lsho4$<=$9O^<;18Zn*Bpfm@ipiqr`>#
z<JW^>C*rVK^(bP7n*}r~*yo{~_B`?csA1P4;I5?R`8dl0vX2Zcc|dbd3K4XfTG73)
zi0y}ijS>WH4ID*{@<o6CFM5xa#9lIeQ)8MRHTJ=Wcv{OMvayq;^FB@93oX2$lr7u0
znNA*GEU1DB@zoDIohYhDTVu0EcDGgP<oqrHalGWwJDJ8XqDpVBT(T2)pQa&UT3N;l
zebdFa!QDi4g5OrOVo~pEJKV50-Aj@bh=!#s9#}VAb*y9J(d}6dS8CChdV-m-P9}m=
zOeQPa(-6;zQI(zW-@<<L&y`GFLb|E))8E?>J^p)eV_5#I*_H5o%}cTak*;8_zBSkH
z02dG|uJ8a}!?1i-Z%!u&5#dICsxh`{iaoc~)Qdf{bYB!H3`B#skJLe9FeVM%HVbal
zH7k&DkIk_{%Axo&C-3dg)=3euTWHz?Z(Jw=gZ9<&-s$Gw&oWot7Q_1LxzN}~I3}qO
zJhIN-->zf!3?^L5uCZo?uaDYHhR@|H$GTt$k8BpI8jG$C4}uinLU6mYIxFrgC0)cm
zK)||ULo0;c8AR$32V|Yrp8ROo&BjLygFo{eA70Lh*Y*pAUwT5!K{gAAu;&SqzH{T2
zfAvpsAcCW})55dN*}Ht#rzu?}0<Jt;ekP$yMfKD`yDGym9dS&h^JEi;s?qen2o=8K
z6Zp(6#~vy@=&}b@<abv0fczeVhjefm4@?0KIRkB__vB8%VSPBCGMqy(;v3^e^o^5`
zt{9Ot+=Ck`s>c<~R@le2>m)0Sx}9vu@=~?Ft?!ux?l0_ZhXbkp*{g00G!MJ(QPCLR
z>iHZC3l`BYv_KrgvEQB4LVD!huTQTAi!5!Y6e1WV0$^PC7Jp5xs20yZ!Q^_fVGcnl
zt~~(&LCmW&?tk%GRNfgq{XB>ul&}>d=uKb~@g8q$v|ebzq@#52d&(M@d}bRoai?a6
zax(0v6^m|PY(P=69_L5ajx;JI{f#a5dy7|x5m)sNR|8L^6D3QT?^fohW!n#@NVX3u
zQ*J)PSERe@;qpRc=(_=U<XBJ<&V!_P>==ebmdKKosuddh0BP%U^)`_0RtiZrEntn4
zl$TEM3CoUB(TvOX3HX8LTp|zAAx^mdSs`Hi?H5LCAGX;rD(4WN8=uDmF#B(8Cc2#@
zy}d2h?TFsI;;B)h8DIp(pK>AQlh-fNKG0HIQ851Aeogb;f$Jp5@VklzHCCz29?2i$
z;>%ss{wgiR+F>^kXICOaEuvrVx=gmZEE(Am`kDxwR0;&D9QVq9d%P|N-wmY^tar_@
z7mw22H!6X#MO{QVl}a^IEp#No2{{-#yh5EEb+hg=FK%Q1<$m4@?7jO7uaAf=4LBLv
zTf4bP5Hn-Mk#{kM=*OYTvI=bVtz}l00Z&#ju-<Nx?;D&Bat~DPLU8!4OQ6fO2$Sfg
z0c5I5E>_UgK&7LUHvm=p!yNS2Ti2n(`fHOXFF!!p__hbh3AG`fRtJr8RQ)4#1gj{Y
zI!F##uMr=X)4lrJZ=#R=nzCB>sT2d^(!IXM|F=z!8nfkvC_JLv`(&<yT2A1!=!D<F
zV26tSCbKppq3T^2Q9f2SLX{yWm({y>T=o`Z(Q@^#HVbl|NM0Mt6RF=;Mqvx9t{hHy
z<4xH?a;MC{eJCgP;fuSC;)D>y2o=A-&JHYl9Q{t<qX`0F7oB{G9b}287{?i~+-M!g
zf9=pWk&a-!R+YWuL*bRnQU&@U&syop8@{GBMwlLi4{0QP=OUSq4tJTne{EK}Trl{u
z(n1Ghq)cXdHhlceIv)h=!fcmxftSbGC4RqKD3+0w$nR8Iv)s=Q+JN(2a~Vi%@MQ!d
z?{Zrk9XT9ac2zq_%z7876lRtX6Q7{ew;zf2`ol**FJ`nc{+KQWg$*8we+|}cVuDn=
zJrb}FYDOX3M~dDpcP*Q^%mcubrJ^Ety<~#c4U8j8;q$E!LBu5%O7+)0MVX`}pvTCJ
zn|q>tl}<06rjp354_=Cu_eKz*i%X#?lLdWtV`zE5*L2WLJD<1M?IVQtuwI@QWBax-
z$HaA<S`uy0Nv)>A7)o%kL9tE5<C&Gez13C>f^C+NW|`djIUFO5iv1#yko=?H9fS(p
z$*vnL#vN?+H9i}aS>nL3a>QbQ)#?b1tH@<?rGR?VWMk7pk=}r{#LCg<r;Q2r-%#!|
zm`8|`Mu_B+V(_{X`v}4ei`>N%neY7b-unVT>%;i_d-mr{n|l3qe-|~=->dQ+8zZ4C
z{elxk;{<lxwo2uGb>%O3%{*?o0<{nS$q!0K>YYE#!~&6#Yep2vC;8!zW}d5R){cR7
zKw|df6Vx31rnh1+$b=y5orTPf-#O{Ro4Lw_C-N5AxNtdw!+;A<7=y!i<kg*G?GFVq
zx%p_wfp#Eww_N8(jwt8j?^Xld0!NP9=!I0nV9hyC;0(+AwL7Mac~pSodIb~zda;Vy
zKZ)Gsl5=iiscs2~!ybT!1ExHI5tOa>ewPUUN?j7L7ZYCeP~o``2GtPy2}8prvT^@0
zo<C#F*gg?W{>HM=qZ3~wHq&?k`)5>qm~FN;8@MPMMtgTbOpT=0rAi6go;I0JfLj~s
z!2QSa(aNv0hs}TkDb$EVx6D^41hg8gn=QcVya!VPOiv^J(~np}&xqKTUpHpz%}erA
zu{Wdj?|MMJylnFtC(PlqMjgMuS$J#ZM4^{ztU}{4_JW3yu+~;^9e?dlP{)+wpTRoU
zw&}Bk`XOgk+gae)LL?<q;H-MJ8uqlS<x6p?TM;{ZJ?S2WzNJ1x#0ro=a*iID6(|Q-
zzX4B`=$4y-Ek}&rckhyj*M)shHMFhCc*2R;=QvsnuLrz9yg$=SU-(DB&U=lv>+i@9
z-ai|hXc%?)<yp1<dB>b=?{QpRYQP^avp~Y5%`hO9^K;c%lQ}0oBws%HIA1pTA^->?
zP~WrQ=|Ke;)-J&J*LX&t&*Q;A)523PE~-%kyt<f9j&xie`EJUe($^?VwhP1gVjWyN
zz(kPslMBx2>&T0-%9%EEH;`A=^DJp7P>%<0${qjuwl7Ep9(vl*P`Jy|;pT{|MfTht
zGp*XD*$LR#t(hWmDcW|uh+9{cb~+Q_YzhdeG1m*pvB+Ou5hK}bTHuYg!8oUDZ}NU<
z=>&$YXnh)_w<6!{W9CSn1X^@6>-suL<eUUPduzL7(ppdbTH1QVvLC6BfdQNZ)a95q
zw{RT)sHon-@sLTR3>?@KEojt}XOZQE&hY>jS^~nRI<B{-@em|H#+*c4*nHOMsRx*%
zJI=E=8e%$)btGoxJfvST39ni^{J<Wdn<>hWcQyCb#|*5ONjpK;#4lzA^JVfx|IjLa
zx9M{|Hi`ifHy$zRX4YGe(ip`YJX^)w(lO${gcr1a3Jelf=WK=!pb9OEJX);xCEm**
z9_+Z1rLs;}<K!GD2A|0&=iC;dDGdHtkSLA~EUY@H6Hk;mJo`D^xQ4zg$ornZ=$5sr
zI+OHjBeMpc!VR~aDzGWNY+hP37pC${-OCM*T0sfCo<;=GbPi7!*lOA8M^TTzR+`ez
z!do}4<NV8rpRRJ-4;@&9XuRc{aq$@bB$+PLw>ADCg@gzphZUmi$l!I*el;GPFu9a*
zf;}9?<Am+?Xxs_qu*wbRtqsf<J)vG?*Ll2Us7xs?Rzp|YS&B`02H<`}3vexb+ov43
z+itPuE)3~R5Q%9Mb}<f~HZ-C=<&zyG@y^f`0Tz#<S*#3~5@_%c(NrH!q`ZC4r3LAH
z6N;Aft|7c*x+Ts5^WEA_;)r@*w(Q^Fs~6Xq6kZ4M!zCgmTg8S0(X6#kmvC$#P?_CQ
zAy~yVbyy8#69To(V3Z6zghq_`&Far@XwoMIotLZZyOy+;V-YJ*8*+-+JxqNTn4E!d
zy#wl;vnZb~iYkZ#1sv#U8kX+vcle2iavT99gK%oG&0hX9$-|4BfdGyLne2)K%nc_w
zp(I_K3UwxX^#XBR-a<(4)AFx}amJ9dv!=oIuW4er0H!qvbB&sdZd3h0M~%04>NHUo
zm$Wn58a5n_l|iQwuz3Eq+$c7$B2;rmE8Dm7MYaB-Cf_80YdAQ*s`8n;(gmL?3GK}9
z`rU>K6L@^<WPh%y;@4krFqcnPJ#Nm~COU_w`w2k(*YBF<6VYz%$70QNL@0ud`pr6~
z%zjgWw1XNxIvu|*Lrve>FkmC*>|*6k<YAh0QX@Os&NY$jQ%|j?pafi*85Vz6AD&ff
z7%M4(fCBZ}W@CvXIA1X5iSmae*HZvqSbn+vv98?p7hZ;(t(%^8<VP`r$z$KpO*J9L
zgy$7%3d_I}N(@@Dcb{ID<D<G)Uix^=)31Kd-h%;&PG4oa0;5gu%0^0cL7S&-&((or
zN=+(^Wu7B^>nbsVXeW}!D-UL9JOmsCdDEcYn<frO&8JDXg$M5tl2%^jC4KgcR~w%G
z!ghEP)=&v~Qq4$g0w!941<B29^IHE&MxYc-etogdCTJAtV1?*CuUl&xrDyIl%<<?~
z%0l>Und27?jMH<)-s2X=>Is+JH~)RkCFBx#Uz70BmBSNqx<3eKVg)2bO?lv(ezOP5
zr45LIcm*}#i5%o?5q&bF10e`@NJVZ+m>tTwhGl{(<H53$Z(bBN&G3t>S#dNs(}vrM
z@|vQB{^~m_?ykGPw5vgMw|h!o9K{^}+`Nv%%YT?ebE{xodx8Sr#lww|!NpCk@gHP+
zas`J9Yegd9B}f~@{Ta?Urh%pWbXL^eM-dv0wK0x31yYiW1=M4`2wKC6YbxF8YNSzx
z*xC(lctsFVVyU2QQF6P~OgJ(pM0NA0B1-~pTnf-(vdNfC)3gC^b?FAlfWUiAIWJMg
z0r=DMcaXqs-QK9JiTh2Ep#co8&JNlqG&(I&xo=h75rZ{ErPd?OcMOQc6;pxC{_Mat
z)Pbm7f?v%69a4}lh?=^sVKu9G_t2;Xi3qCDHg-3~&4gn+s0wKgPQaX5Q7adIC>UQg
zvs%$T3^o||Y9LJ?3Rk38IS1H(=yq_)khLqN7<J8ZsS=2bqj&tFmKd+85JX{wMyGpg
zxso^@8mllJI!g;S-oCu!W!+L-z@9);P!FF)E&g``hnYK@<)KZ~hlpczmF>)=C{s|t
z&5f-l76y?P9?9ltcx$Qc53zms#<(FF8!m`Frl_Nl%BO_<dNTW=6G6i#YJ*H3RLV6y
zgW(TkIF%Jz_9sE2Vxi=oC+61Qj?g+#b@sVYTj+P1>Qi+(Rs<YX7_(Ru(xFQp>i&V$
z=hT^iw8D$VNxklH*dhFp%zd*Focc}R#2>f7eGNUNA^K5OSlnCIj;ihuWx3uHEz`3F
z!g<OTu$XwH`ckCFg%cD9HV`AOHt{yn*5}~mHWRh51x7Oh{yN<kc+oqu!KxLhAq3D|
z)qyX8ep51dyj)2i-w*&ozugumpdp}!QHmS0o&!P=*ygDx7RrYEl4P#W6_yvNscBs}
z#V=sa@*t^9aCgOc8HsC#+S}BL6Uej+^F3b~AYfsT5ro-OS19`#UmXPDhKDSV@B;9h
z>3Kvx9S+M6LgFJOIP~}0Wah+k`6$-40vrVHFEs12<s*Mr4#?tT4O>@;b3@6#9E4+T
ze02PJT9WWeNbuel6GXX;Y|LXxXL9(UPIO<tyj^-U<Ga3xw)L$Tdsb?p+<9h*?JkX;
z6}t(SK~0hQ${;198X~n1?S6=gE{m?9#6wmMQ*ewQT~_3V&A%<fjZ9gceGwD@LmY#{
zL>#!$^OF>^P1s5+=FOnrX+_-nR2`<Q;oILztLu{2<nT%@_=fJMi<zL&d7WAU{F(PN
zTkongT|W{%j7AtvlTd%{HB-gW9iw**5Yyuxn>d(P!|#4R+<|VLb!*nBE`1J6$cjZ`
z<#O!K!#s_1cV_M(C5d`x^)y#5qv={OmLX2pryl~jHspb73^^Yop=$ekwx0jl@zbQU
zlcMgOwOS6Qn6i}}+Jy9^+jhGRrR$cvn;XOeA<MjmOmbKf_g+r8WE4R#a@CA5fA4Hv
z*2K2)kjpGE&pKzU!bXx&f(&i^lh$U4l%k_$&Joe7deRxB>=1n<V2uHyK9`dS>6Iwi
z5I#;7Ets!?q?S~$+^P$O@aUt;zN%ZY#Yp+uTbTg1dVS;WIskqUI+!gaE#FN%)eE9I
zc9ADYHuH*R%I;;#I?0K25%R&6o+LQ!L~g_+jn<zwG9YKpigFcn2W#0q$7FREScP%k
zu{msH{w?nh8t6R814_!y4Z|>an)Jhx5i}GVt?+C~ENj_j`jb>giLhl>^2LYfNuzWi
z=Kz~^eoD)EqaSDpK8P_;5i0TO#~z=Q-Bwh!HxC8V8%u9&-n&0k8sZ&)6#PtM2wRO=
zlj4LmB$COuVQZRb2kJ0a)F3CmMn^>2w7>VoxmzsZri3+_A3miY$-D83@h~CK@=vVw
zSvoL8P_j-(jQNNj11^XRe^dnix4O!Nmc%XF$l>H1uStT;$S=kZk&fwEFF;8dcuvF2
zb9+xP#_Y#>+Nd{W`e<SlwpZb$=`T<y1d<Uo;xo0=b9*ulTq$yjq$V4^V0%x-uOXFa
z9AAPScR%kJ^_Wlo>B+6%p#|hVQWJxd9hWapDan)RcgNajbYwB#7^JH))Z%Kk+>!O`
z)yrFKS_WmjLuO(Pb}aoZKYC`kYH|doq!>F<0=iOI$H4$$4)VVp{B{Yf=6wy?JUjgi
z_G(q<)HyG&&BtoUBY%fe5s&(zK5Od5?O15J8R3ip2|FyDN!6tYIerUCIQ*`B!1*}M
zo~-f11Ye!QW6I}(XD!}{-mZB>ChB`GweiakR<r|wbOh&LXgXr!8%Rn2lUW5${R@J~
z`#a0w%j40|lcuj=xSZNYuRa%*uPlTq!tC#-fTat0Nt2r9<J<<z*t<vrVJCy%X0XaA
z*pU{cRI-geNZ{+J5O5rj9j|w=03S?-sn|z<!UniuCWBE*%^gsV7~I!>sFEKF*Y=&}
z>I#A7I-m{tmZPPkhW0mC?M>|MThho#v=f+Bz`=ska#mV`gZ2GfKMnUpGIX|ZZ0I-#
zhri%@rN`_cdqm6!g_7A|V1t!1O%H>euvX-&By<oMVmalbU^IS)ej0}Kv(>Dwt7bmj
zn>LXF?kL;B?GzP$@^3$q*b6e<XR*DLHD*IXvYzXX+Ub%Ct3TbIJ<9jUr~1-W;~3m%
zd)`)gG{6=V)*D@EK*hah$Xw${pdlJDGl4h+z)GIfb#R%k0pBq3YZw>c&Bqo!&AV-K
zL1mroo3LQse2~)LI3&R)*)#=v>Xh}*KE(Cv?s?AF8eT+@!d=0D6INoee$|#n(N1@l
zhZj9S#sZ{7sJ1dZg+^L9u8EupT6=x3dq1b~yPNkUEP}&7@W7^Xj^=>qAmsH)W2wQw
zCRQ-h;x@c*T2qYR0C@50X07S=+ahAfs3Uf~myilDsI&}Nz7~bv^S$<Sse4>u)3h>4
zlqq^OEoe=(a67~`n|n=;jspTA=l9Y=Il}NqMB)gbY?7~W@dlR$;f6%ON^+;P@tAju
zBgjbSgY|yX!8}iOVw?dMLLfF|Y?~RoAeY?G!>HTin&f&wXf+z-OTZ^82(#{>oR;{Z
zFCB9lSf`x7>I|Eot0|^3MsrW(UA-<tBlGv<my!HDS1M5vX=`cexCF8#DS_e*C_O5%
z_M+rb!(Tkb_m6=|Ej5tA9P2Cl?CW^D=W{z1WSN~C3B`egs=_O&vwnhmsF?Fuo3e{V
zkAf;C${-N&@!*~F1!znl?@CMfO~Py7_PaV#3hpBrr7u^G@(0zlz55#UB7;qOYzjAP
ztzdBo!!gX`!Q?}rUH)|?J8z`n>+s6pLe(PZQOuq-5H}#{!NzJpLMoeQ_Gej)p<fs`
zG>0iTTI2w}AH@u|!UTo2!SXisVUJk2uk4!AF(dbqPGn5k%U0%G^kJr{E9e(DiO4l?
zD+rAM_?R57OB0n`pCzsymRUpycuRC-U64al`F$`rN!t@Vc&`+FXgY-~QR|gk)?)wz
z?c_zey=40U_6^w23d|LoDpw&x)^swQy#$Y<Jq!4s_98dPd{iJ3IRy%}<G*Jm`%t=g
zZm)P4sjCa?2ADn_h#sgZRW?F>P#XiN<qTjJT^2V365|wCU`e8ASu=27U#4xCIQyk@
z6@=Cb{=TPMrTHLTTpW#qi93~_QbyiT;@BJ}JABZa-)x}-G305)9@Ceo*qZVm161xx
zePC1~0s;zbK>v=#<A;}9F|EjB(n#1*V-eGx+e}9R)?WaC&s>{!v`T64J@u+HTzKXx
z-CsWlCjvGjd5&g-<5=%9I(ITjY2Y^cl8XrONusxW@~dH)wj7_fbjRU}AeFm@{R$u(
z2d79HE&KzdP1X|)j*Sp){IhmW@`6sG2iKsZvju|*G(-MB099*|`8*=yBW;rvN-a}c
zs2G-aFpG=Ln(Rr;?|c=*TA4+380Y6Pz>xI?5}ImdmM7N_o8dJ-(w%wa+i^7=M1CAQ
zTRNsqEU66haH%z{RsrQ7Cx1xH_3Cnau~D9>Z&Ntjn1Kp>eXQMY&u-NbkJ9m5$9R@q
zHnC@Yu#sq5Gsp<ngk8=nIW+%vio|060qLQMBzv@!7fLWDl;uB)_+HeRG|e|3)ZG%g
zI*(mVH#I|h*}1Ws=~+l)HlhFSU>)JH>UXc8wUF8ffxE?wVKQuDTE6hL%t~f5)e2{*
z2irvUq~MwPF>ySR(MZf&$!*Z@@Y^1Ag0`@Z?BFaG*tQoWJ8y7@`48x-n9lCXmn{tk
zq{o(7!uk0)VfL4*vu#U(%B}3V5zG8C{Mk7?6NDN({@B;M67^%8kb+*c3p-{BOR|;%
z{|CRSik{K^zBT31C$sxiYm9P6G|OgTap$Gzq{yY?acq^72c3#@XVasF*J-k?ATSo*
zjoJ85j(gPx&K-$4PjML_Jc{_ORc|@Wu7y@EC^qM&A;);p<P_Vs;F4=K9S2eGFXy!0
zOe8oQ6)!ZevFZ?2Z|#w-2+|CS@TNtl_<Q_l^9i%-31RrDc9$bKW?|!X^j(Br<b0%~
zQPr;A#r|kh*c&jM9cMTYO6M&jRLqwWM_Ui=oi#?}uM(*vfLG3_vNk1Twanhb6Q;Ek
zC*{S${o^iy6Ifp7&){u`2=4(GChi7kGawcg$Xxu!%#&Mq9%=Qi*EtTGJ`hB2eoR^q
z7UTYSz|)+|Ak3c1&b2J123`tw*v777zoZ~DM);nWWAO`}^h&16(bcV8l2LURM`^p0
z(0Z2HWk3Nq)`5=0#Lc*SHpYHM2Z|6guOOnsx2%7%d<!CQWMs;<cq%EEb|da~3wO}$
z!Pb~jNLHroN(wj}H!lrj-c%8bXp~M2*#L@;ChvXtR~aI<6`}ss2h44)3y##P?o(1x
z!xf7*DW<}Y{E_HSE2pJkCsqdpn^P>?^TJ0keY$8<O$|;Z!|Z<k)|7$xG7AteJelDO
zL)VG8Jly#L;oKI2p|5!~Mr_7Yr-1dwE4V$zQX%_b@W$UDmjR$c;7VflkwzhU(NX^I
zrErj)4`J~;-}>2r(}YbXx81(rBPApnG(woLB*Iru?xZ&s_V)CBqEExy0nBg~Tf)6;
zT5qQ)xKyg2*RHLb_iP{9ZkyuW1uRylXP1$nrj@-*>h>f9*dmOfcOxcE34J}VbbaZi
zA+@AeFnwSwb1(+MD!-;684o}wQrqB|q|FX^M0;n~fFO2~SnxV?Ip6ize%VPAe*;h_
zo}Fcv)mZ|(Is&o7MGMOV_XD{<n-L9uvVpkcF40RFv$#=zSx*|?ZBXo#R#(e{-5;CL
zR)nb5$q;yDgM@S?ph|0Ue6NOiIB40{VbdprQ`XrA81V^FzS6S~HyT}3-jy40-hZ_N
zRTo)7Q>n^C8BJE_l}Iy5B+azDUTS&?d9->|TbkQDGsZR<FHA+vm6w;ZbdmsUx4V3>
zCx2*^*)&GIPOHjoo_(-$B!mRbg-U33BW&*6ThTI2-c&*hDxH<<9Q|tYn5z#h`BJIO
zoR&LYRCpn_hy}{^Q+)IP`@Zz55sH1_F~IV*Dw}VPDEl0jowehfW4*#>V6vZrg-a2X
z<cDLt$qKx~4hJeOxU8k;WBulJ1SR65Qz0o%YhOBBTFboxJ@m`3E|DY~e8xiRIJgJN
z9fM9iRxPd8nH@=MK!?ZoD|4)Tzq`-<iOWUWzsd@M@9CvY|0=Va_R8BYh4i-t6>9@=
z*xv~Z388}X$Z_|k3KUfxt}G7lP$!wlK&0O?cR9UkaRD-ZXvJ~7KadBbszuBf$Mc`t
z#QIC2^sZhInVt}X2JiDQ+H6_SL#;lFc6ZAFOb+^oWQ*ZcuNKIInPbbl*4Sm^&k<Jz
zA3Jw={b-FlG|@$Y$N8H<Vv*}3rX${T1Po;v9}KqyTrV4TfQumk9zO$_?Hqp_>B275
z37dx+bS@EnzK^@|>C7JKGv)p!@0vO;gY817^ezU?Mk*FYq#|UU#SA>98E~gBZ3X@d
z0P~Uyx{(!g<*g$~6ebf|afjszy0J4BWXv_Xd7|L!>@cAp{m%6K0i>U42=VcsBas{4
z;?Zkb1o#yYpzI<gi!{;Rs_2q#eBoUFxI6x!Rx!ZQcM?|(wGC)b=A5|0==V=uLX4Qf
zYv^oW&%8cmRrs2qoGh`d=OUq3k%Ui01*N<10MW<u{2{fLrm4iD#c`lwt^xbedeI6>
z?y~%8_p~GVHxc_lqe_!>&!qg{`a(X(dggoUz!X)S;cDaIv&DYKto7_XbU-$Kp1|U8
zLYS5(7IL4cOv*9DOR+0&bBD6~1<&_s%Hu%7F1b}4lI`Gltv`=EGktkPM4?b38cgW|
z1kWC`fP`OB`EG<iLl1k82}NXE(Uw#rhevY+u3CT@0pA~I#KIv188+{C$`(0i#V+R$
z@Cn_*8`s>?kNxh7kr3vwHP)tN4Zn;;7jHDPzo(nhEDuA7_EvCg5h@8>@qWJ|3Ud5t
zI+Llm(K|$7Ih8hftZmPzyoiEJz;!$vgHm?g$4$YE^Sy8TQ%~Jgd$(c$2vYh57;>|@
zzqezMWi01<dKm}0>4*mUv8u^l4yB7oOd}qR5A4##XpqP;@a2Fc9;DA=xGi|?Q`VNA
zJyFumLlRj|JnUy{UjNVnysF=Kkc@!x7V>?GOpKMs)K|sD|1sn}9-Rz*QI>=mN&B=^
z=}T5xV>E?-mY?{2*3VKW))lbXgrKlSzq1oOW5nWik*gVXFbabLC;r{EK(EWUCSv(>
z?OVdMN-fNdtkXW$Y7p_@Yt`A)cb(>Khg90~7VARKW8&u2Zx4nuOE-S9Fo#kvX_pEo
zDm#nnp3V)Ue~wy+>9__*%oGu?w9OrTaX3dZHSN~8eq^#x4b>Opv=c^%EeC+nt?;s#
zTzKiYm$eOI9fDM0d8irrrC`*azn5z8oh5;xBmGfS`(8r)XUrFG6faudr!-}9Aqn5>
zqE`QEqnQ^3YBvgY`0{kM7jyY3Fi=MHre9ZG>=e9?tRdZcej+4I=~`9)l8rNt<DC(1
zNfk1Vu!`b&hx=*1>3VadKn$q#G~YVnIzk~_j~Dc<Lz%hlNwRG#fyM2Q@t5;ye!W53
zI$<?O04XJts<PU(q1LF6%rE~=h$6MXD^i2$j_ZeQ5p&kw_@%~r&lkrrcd{Uw;=*^-
z%T?vG$K2Jk2zvNNuVfeG>r87NAC>-q<Ev;SI+8@rj$7e@99&}gzHw7K;waQx&K};A
z6{GQ2=}|_eQH6tIRym{5+i`ft35_^CI<6^=m(TPV+{{0YI`=LwpCd0Zy4G6os>VtW
zBrYJFo8FK0cb~<geKjr09*d~YxyNmIyKx#JMF!@IQPR>bI}`GRK~Wc+uYf)GW8!#L
zsOsxs3VG`)#|Dley`I9UZdW3}2;kz?S=H!yp$kuou%FtL#+opksF$PGSoOWCCqi#t
zosb|%Q^08KTEUhdneogieYrz-=-os^keek<2Cwhp0BJ%+dq2g!CKvWqW@qRM;jFG^
z$zPj1=#S%0W02wFXy-=k16`Di)`c=KRGJhgQ%N(M5GZJ>StK4w!jSOfGyOZCsgRrK
zt+mWK7EAJ^?@@c<1KBmYt-9!<1G|DX;CD<Y?ZuVp{I$XsEf^fUSGZL*n*M5l8P?zV
zFbnY?T`cY=Grz(C2Sq8y(^4U-Y~EF&YT2F6UkwRKC1d>VH`qu9Ans1xG4hkoeAEW|
zIi)Qqk>Gfn%`Pe`YU$A-7NfJ~fEqSUCGa2kl04dhYs-XLcf~6nW<4vZ)dxU6x^!O_
z(m!>2j)kTUJXPu9_+X=6xo`6o*%o^xXycfhmJ1LmDDj>hn>{x9deX=;o$Eg6FqKd&
zPWj0SK@tPwf+;kipFJ*`vdzyB1UZiIw`>$=V`)h*k1`vpW<Op3<~pWB?$jRn{SjZe
zv#9d#L#ri44#S`_CdVE-Fa%Q>k`tz2-qN-=B{T%khBJewf~fl(57FyMy5B9WtFhF8
zvd<c9fmpZK$O|Eu5`(C0iyonLMpzL~!ozOo)9Wa_nGq%sAw3kX5v!Q`0<nv7dv^8)
zP7BsaGBN-hfkr!HaGTO@Oa4MG;>{}thSIMt>!C)CLK8-HrcHYQs%gWwAafhC0PYcK
zdn%zYAsqWT$pOmxSC8!YTA;~jawu0%g^OF&nU*3SNYdN$Yz1B1s<a?Fq;|ba+88i7
ztUL>x3*?P$^6L{^mhj^UqhbZ52NAms)P}wegS-V2?83h4VK%3i0_g7%id>sZ(`uxZ
zC+~jIISVwW!J&y{&m^alJkmEhL$RKRmZI5Yt4)w&_pNa@I~*-NYBq6n&tq^08e<jr
z)GxAv1Z19X>EtT;nhU7#D$0`XAi?_CNDI3`yTcwG-d82>I$9T3fm;*pSc#z}+c{MV
zxcSB3sJXnU0j`dWU2=9q(#8lr6~7c5Ccc{_L)g=D1uC^tua3Uw?^Q5Ae+-ibJEb=L
zw5YG!@;;;81JW+a?Ev>OP1rOZHG7dhrRK}&sYz!UmBndBf|d;kar0Z=@aAXis;*I3
zeG-|SUhp*vHk)8#Os+K#sjQ9f36(F@G5B$~(M?x`rq=Ruv>~EGwo=m8R=DyLPO+0J
zWJ0V4$_U}8o}yz>XLb!q!T>atMI9;&MzG&|WD>$w5e~#u-SE*#ZDf*$dDhws=<9Rf
zhqSxNVCPy)#aPA@zc2WR^m=w6S<DzyqKC5;i#g}_jGBl!G0etzBK7g2V_BMvKxyW<
zcohEeK*Usm*)h!i$vb0WU#q3UW}}N1i%k?t(N=zpv}~BuM*qTx0NMCgPj6#)S|#sl
z>LsMiV3}NS6!m+#qqI#@$}7WVfeQ-subLcZ2I;C8NUUa}!fbsY!vfeiX~Xy7g69*d
zWUE0RD7(8=C<LgV6-N)yy?p9>7P|}MfV7_O{bo_ykyz|PZek^C%4iZ%_13io+YwLd
zNo`G3Ggj)p?bn-h$y{<WSk+429vY1}IPL4DqWhfIOTT`(6GFK=n^U~k{0hUNs;;oe
zcmH<p8+}q<dVvF^ntX*7PKKUeYV9I1AkMDn$VUYwQ1rMw%@%x+GNxQ%%zvKhzk))r
z6LL6UHKpx%rL0f^XAECJ6(5j<Uun%@zFV*-rZdKO%=13QBYr}MO0^w`SO9+WgCtBA
z?rhkbCsD7nxem6vMMepqLS#dmhfm%?E8x&r9>W2syrE(1{rw3FTOfl*ZKm|HjToHc
zX<x0rwRrNF67)KLGx=usI&2idZxc;zMJ|?aqy30SQ}t0w1Z9iUw5qxBNf;*N4p<2)
z^f=;{Q{tUxP=btDjd1Ex>>SmP{nMz*Qk5ULgbRMSIZdAol)JbjiLXm+U5WDHv*^G*
z(M3NE|IRa-vIS*nrY;#fR-?q4)^gZPu8}2maaF}xn_Y0oajK?UwPK_n4wW4`c(9lS
zf8H?a0+{*vYwBU7Wa%XM1cuuB#>94QY1Ld_o+J?4soNO`gr091ip@(LuVFs6t}sqo
znbnStZ*=|H$_K|AGJ3M^PfzY(I@SomSlC|jkoJ9w@~D5d(V@|YB9e+Z+qcX}+Y7SI
z|NG^s6D9IBFb3b116!A*x;J22v#Zoy4=vu^UnL3~0nh&Vo%1;gjL)2)ZHzM<T(Po!
zRd`32n%?}!T1sRMrf+|^iCR36XF@K7Ans<UDKUsH1GH5C&RLg_(YRzuND4dqTer)8
zCyDckqu9pScdI7|%`GYtQW9sxoP%GTK@uvLUaYF(?LFM4Z9Lv%J~r6*6aE?9{OXo=
zyPN5v(d7wgv7DX4^0;Zap5hz8+#se0?ig)bN*clVnpE3@{q*<vtgHBeGV~A%D|gLE
z*`fti7)zcNI0CY2l+6;0_4_vRo@@x0j{==f68aju)Dgdv4rFHFSg@+stZTOH-1EGG
z6Gd(nA?a`~GTgGt1c>(jSS>RYnSrt>wz5(JiQRM5-k!P?fxk;$2nU+!IdYFF?M6K2
z*Be84gXfqh(S`8|?s@u@$o(_bDes&xl{|d6r}Cq=rsvwz9-d;~DmVWiQDg4KMw_JO
zOeW|Fiu;Aes(NfG7WWg@0jW<HG1G^Re=3#9YBsWPelBPyD%gtk^+a51N5zWMnn5j|
zJZo5d#tNNt{YCa%8Ks8meG08u%s2YpDy#&i3{Vpu)>3`$atyJke#lqu{9TUxT6&d8
z-=AzPe_=*2IAG(`4(<qfTHh?)_Y8STeH~cA@)yfdV_sA*&(l6`u^uHn=p0d5OQ<SG
zXwt)FY}t4c8ZW@F2!!2Gm;x0=ohYMD<Y<y1M~TC_VZA!%t4uGP^K&QGz}gZf*jE8C
z{zbH{CPL6u#v}FCW8N*Dpf?zpdc$d_>r$>O){122(5U#B>ce3;0LJJ6#LLva-zny-
z*IXnHPn+$-+QcT3DOAK6rSZ$ibaiE%v_ZIeV=h~rg%plX1+m^?#FE}Jydsp<>#tH!
zwY3ARz{fn;(+DPaM!RYxduqLEpEX8B@r>xGT-Z<=T>h>Q8^UcvS1{}jcyBcdA%aTG
zK?<y0rBSQrG-k#_5-Xy7N+oJQmTq!bk;02jZ+s{801C@tlKtCy?=apq@$GiMxXIi7
zmB`TrB?PoD_kdMlltM4WC<<*ICr@yoQJDMRF2D=0g6=w9U;kOH=qZLV3a^p8u)IiH
zWYt3|QI}xCBfN5Yz>caLNdBr1lx0Qckrgu&B%h+Q>(T3$6wM`EtqlvQM)*w+xG9+>
zLif9ovrmAOyu~(UKSx%7ChMG5@OO$QFB)~84*^xzdM#2u!Lb#nO~5HhDm3`hX0e<`
zpArPCaz+6aA%t^>^t*HZl~aU6eDTq}sIgI8yq)3=2Za_fuzv}R@;c~Dj5H5y^@I(|
z3S&rR08~j}WV{TV1H#IsS^rudKBo~?N}KZ?%8v^%;evdRz+9bGz!Q3`#D!&e?5;I-
zhJ00b<jj6P)V@hdb!qeY*9be0MtzK9(T#H4UNBIa2D9_YkCV@9<DO>q{q`9n$hci1
z%j}3BE`nr1%1#sH{k*B76R~Cs>rwiJn58v=Vj{XWY_}cVfgRx1{2h2fIc9}EYa;M8
ze;ChkU{eFMmtOXq#%)?O^w|=N|5TCRAAfZ0t>noFEwu)x_39RKMjOVUo+!H}MZKtc
z_J@e?<Zy~v(P~1JntK~zvaMl+T(~{5u9l+E=x8lZPw;F^*xDwqI%kvC$PFrqA`y+>
z%nSwhSlzQ+BS&TS>~eBq`*#jf*1lVqVIz<e-Ag~HK6u{elSYV}+J!mOy8tvqJMNJ=
z7$FM&3;-aAHE6?T#K_q$L9i^e{Q5CjzWavBt95y-?tTataCmVm|CR|s?@Y7;{{3(@
z&EFiPribnQAn$yCHR^wfFZubrs{;+lQ;5H<(7&&N4}7XfVF@|L&_CHqAF&ItRp#>q
z4L)LQciv*vGx{DD_D|?c)O8cYB2pLC`*7kh`F1>Hoeo)t0}lCcJY=zUU)?yq0-TKO
z%C#l)jx{w1mkDHKQ;X_X@O>NGJdc{(=e%d^i4sjh4@?(lEH!YM0(9<ruZk;wYVNN6
zeIzZ0_fo9J^fn7brVC%HVg<qV{xfT(Ih?2$UXOuckdNDVXdKLOnkIhd(r^w~C>i*g
z9RolenJxRW#kw(-3YvC2rq!9ipk5-{pbI?DfFPODdOM$_I1hx<eBFLYLKU+w;HlbN
z%IdD||7?4zFbB=H&Sbwt4Bwh#Xl=Y>v^@AYcD-J-`lBToG>VuTw9bo1nr7mfaWfm=
zzL#s}9*)SnoXe!y(mRHrHyH1kXdA7C4RVq-7mtVbDz4UNAY4h2d|l#pXQwsQWO2|(
zT^Z0+u9VnSofXXbi-)O^-ga+5^;OC9DM!vS%QS;2%cSH*b3cv-0La{3<A%5V@`5LS
z%%TG-cWF8i&o|ainyKmJn)qRON1ADzBr_M}lKKoYES9?p2@jy&dFvwxCDbjy$^2uE
zK3(_+9I_BdLc6=k<0xs^*{|t~_pV_r-UtTzkI=ej)5{-=>!#g@josS#7^Y2Bb^Zw=
zmJ5Xk9C}|X9CnBNkHKtGj4CSpcA(B2$*DV(q9WoHpjFdBC5w>uCe6I=f&r2#gRucI
z0#pQ@pJs=|m9p2=guzz3iZ=HrblMdkYhoL7W@`+-IbsX_TB6gJ`c{v&tca~_{kw8M
znbwv>R#WvtU8dwbBSMlspa`D@aMmYk=W6flM)%_L(u#{yGAgD2grFnmv;Oee@OB$|
zf1#iG3G)3iYAqx!V{j<QXtZB0&05m-^7Eys(#Be-nm5o|7}gp0c!aUwDWTq~c*SA!
zX!-AW9sO4Jb@zRjS)<_J|8`i*yBg3kto*P3&W8U<(yLT2F0OTT7jV@<uMc~1fCp~<
pk)7=##3e3gmzZ@3tF`kDx)?<uBf)TZ_s_4NlA^LA)j#wD{ujU7X@dX&

literal 0
HcmV?d00001

diff --git a/pyproject.toml b/pyproject.toml
index a4b332f6..9906749e 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -49,7 +49,7 @@ skip-string-normalization = true
 
 [tool.pytest.ini_options]
 testpaths = "tests"
-addopts = "--cov-report term-missing:skip-covered --cov=borgmatic --ignore=tests/end-to-end"
+addopts = "--cov-report term-missing:skip-covered --cov=borgmatic --no-cov-on-fail --cov-fail-under=100 --ignore=tests/end-to-end"
 
 [tool.isort]
 profile = "black"
diff --git a/tests/unit/actions/test_create.py b/tests/unit/actions/test_create.py
index 5849b682..204d5e08 100644
--- a/tests/unit/actions/test_create.py
+++ b/tests/unit/actions/test_create.py
@@ -207,13 +207,45 @@ def test_pattern_root_directories_parses_roots_and_ignores_others():
     ) == ['/root', '/baz']
 
 
-# TODO
-# def test_process_source_directories_...
-#    flexmock(module).should_receive('deduplicate_directories').and_return(('foo', 'bar'))
-#    flexmock(module).should_receive('map_directories_to_devices').and_return({})
-#    flexmock(module).should_receive('expand_directories').and_return(())
-#    flexmock(module).should_receive('pattern_root_directories').and_return([])
-#    ...
+def test_process_source_directories_includes_source_directories_and_config_paths():
+    flexmock(module.borgmatic.config.paths).should_receive('get_working_directory').and_return(
+        '/working'
+    )
+    flexmock(module).should_receive('deduplicate_directories').and_return(
+        ('foo', 'bar', 'test.yaml')
+    )
+    flexmock(module).should_receive('map_directories_to_devices').and_return({})
+    flexmock(module).should_receive('expand_directories').with_args(
+        ('foo', 'bar', 'test.yaml'), working_directory='/working'
+    ).and_return(()).once()
+    flexmock(module).should_receive('pattern_root_directories').and_return(())
+    flexmock(module).should_receive('expand_directories').with_args(
+        (), working_directory='/working'
+    ).and_return(())
+
+    assert module.process_source_directories(
+        config={'source_directories': ['foo', 'bar']}, config_paths=('test.yaml',)
+    ) == ('foo', 'bar', 'test.yaml')
+
+
+def test_process_source_directories_does_not_include_config_paths_when_store_config_files_is_false():
+    flexmock(module.borgmatic.config.paths).should_receive('get_working_directory').and_return(
+        '/working'
+    )
+    flexmock(module).should_receive('deduplicate_directories').and_return(('foo', 'bar'))
+    flexmock(module).should_receive('map_directories_to_devices').and_return({})
+    flexmock(module).should_receive('expand_directories').with_args(
+        ('foo', 'bar'), working_directory='/working'
+    ).and_return(()).once()
+    flexmock(module).should_receive('pattern_root_directories').and_return(())
+    flexmock(module).should_receive('expand_directories').with_args(
+        (), working_directory='/working'
+    ).and_return(())
+
+    assert module.process_source_directories(
+        config={'source_directories': ['foo', 'bar'], 'store_config_files': False},
+        config_paths=('test.yaml',),
+    ) == ('foo', 'bar')
 
 
 def test_run_create_executes_and_calls_hooks_for_configured_repository():
diff --git a/tests/unit/config/test_paths.py b/tests/unit/config/test_paths.py
index 36a8fb50..d9597cea 100644
--- a/tests/unit/config/test_paths.py
+++ b/tests/unit/config/test_paths.py
@@ -22,6 +22,10 @@ def test_expand_user_in_path_handles_none_directory():
     assert module.expand_user_in_path(None) is None
 
 
+def test_expand_user_in_path_handles_incorrectly_typed_directory():
+    assert module.expand_user_in_path(3) is None
+
+
 def test_get_borgmatic_source_directory_uses_config_option():
     flexmock(module).should_receive('expand_user_in_path').replace_with(lambda path: path)
 
@@ -34,6 +38,13 @@ def test_get_borgmatic_source_directory_without_config_option_uses_default():
     assert module.get_borgmatic_source_directory({}) == '~/.borgmatic'
 
 
+def test_replace_temporary_subdirectory_with_glob_transforms_path():
+    assert (
+        module.replace_temporary_subdirectory_with_glob('/tmp/borgmatic-aet8kn93/borgmatic')
+        == '/tmp/borgmatic-*/borgmatic'
+    )
+
+
 def test_runtime_directory_uses_config_option():
     flexmock(module).should_receive('expand_user_in_path').replace_with(lambda path: path)
     flexmock(module.os).should_receive('makedirs')
@@ -154,6 +165,25 @@ def test_runtime_directory_falls_back_to_hard_coded_tmp_path_and_adds_temporary_
         assert borgmatic_runtime_directory == '/tmp/borgmatic-1234/./borgmatic'
 
 
+def test_runtime_directory_with_erroring_cleanup_does_not_raise():
+    flexmock(module).should_receive('expand_user_in_path').replace_with(lambda path: path)
+    flexmock(module.os.environ).should_receive('get').with_args('XDG_RUNTIME_DIR').and_return(None)
+    flexmock(module.os.environ).should_receive('get').with_args('RUNTIME_DIRECTORY').and_return(
+        None
+    )
+    flexmock(module.os.environ).should_receive('get').with_args('TMPDIR').and_return(None)
+    flexmock(module.os.environ).should_receive('get').with_args('TEMP').and_return(None)
+    temporary_directory = flexmock(name='/tmp/borgmatic-1234')
+    temporary_directory.should_receive('cleanup').and_raise(OSError).once()
+    flexmock(module.tempfile).should_receive('TemporaryDirectory').with_args(
+        prefix='borgmatic-', dir='/tmp'
+    ).and_return(temporary_directory)
+    flexmock(module.os).should_receive('makedirs')
+
+    with module.Runtime_directory({}, 'prefix') as borgmatic_runtime_directory:
+        assert borgmatic_runtime_directory == '/tmp/borgmatic-1234/./borgmatic'
+
+
 @pytest.mark.parametrize(
     'borgmatic_runtime_directory,expected_glob',
     (
diff --git a/tests/unit/hooks/test_zfs.py b/tests/unit/hooks/test_zfs.py
new file mode 100644
index 00000000..4567f826
--- /dev/null
+++ b/tests/unit/hooks/test_zfs.py
@@ -0,0 +1,326 @@
+import pytest
+from flexmock import flexmock
+
+import borgmatic.execute
+from borgmatic.hooks import zfs as module
+
+
+def test_get_datasets_to_backup_filters_datasets_by_source_directories():
+    flexmock(borgmatic.execute).should_receive('execute_command_and_capture_output').and_return(
+        'dataset\t/dataset\t-\nother\t/other\t-',
+    )
+
+    assert module.get_datasets_to_backup(
+        'zfs', source_directories=('/foo', '/dataset', '/bar')
+    ) == (('dataset', '/dataset'),)
+
+
+def test_get_datasets_to_backup_filters_datasets_by_user_property():
+    flexmock(borgmatic.execute).should_receive('execute_command_and_capture_output').and_return(
+        'dataset\t/dataset\tauto\nother\t/other\t-',
+    )
+
+    assert module.get_datasets_to_backup('zfs', source_directories=('/foo', '/bar')) == (
+        ('dataset', '/dataset'),
+    )
+
+
+def test_get_datasets_to_backup_with_invalid_list_output_raises():
+    flexmock(borgmatic.execute).should_receive('execute_command_and_capture_output').and_return(
+        'dataset',
+    )
+
+    with pytest.raises(ValueError, match='zfs'):
+        module.get_datasets_to_backup('zfs', source_directories=('/foo', '/bar'))
+
+
+def test_get_get_all_datasets_does_not_filter_datasets():
+    flexmock(borgmatic.execute).should_receive('execute_command_and_capture_output').and_return(
+        'dataset\t/dataset\nother\t/other',
+    )
+
+    assert module.get_all_datasets('zfs') == (
+        ('dataset', '/dataset'),
+        ('other', '/other'),
+    )
+
+
+def test_get_all_datasets_with_invalid_list_output_raises():
+    flexmock(borgmatic.execute).should_receive('execute_command_and_capture_output').and_return(
+        'dataset',
+    )
+
+    with pytest.raises(ValueError, match='zfs'):
+        module.get_all_datasets('zfs')
+
+
+def test_dump_data_sources_snapshots_and_mounts_and_updates_source_directories():
+    flexmock(module).should_receive('get_datasets_to_backup').and_return(
+        (('dataset', '/mnt/dataset'),)
+    )
+    flexmock(module.os).should_receive('getpid').and_return(1234)
+    full_snapshot_name = 'dataset@borgmatic-1234'
+    flexmock(module).should_receive('snapshot_dataset').with_args(
+        'zfs',
+        full_snapshot_name,
+    ).once()
+    snapshot_mount_path = '/run/borgmatic/zfs_snapshots/./mnt/dataset'
+    flexmock(module).should_receive('mount_snapshot').with_args(
+        'mount',
+        full_snapshot_name,
+        module.os.path.normpath(snapshot_mount_path),
+    ).once()
+    source_directories = ['/mnt/dataset']
+
+    assert (
+        module.dump_data_sources(
+            hook_config={},
+            config={'source_directories': '/mnt/dataset', 'zfs': {}},
+            log_prefix='test',
+            borgmatic_runtime_directory='/run/borgmatic',
+            source_directories=source_directories,
+            dry_run=False,
+        )
+        == []
+    )
+
+    assert source_directories == [snapshot_mount_path]
+
+
+def test_dump_data_sources_uses_custom_commands():
+    flexmock(module).should_receive('get_datasets_to_backup').and_return(
+        (('dataset', '/mnt/dataset'),)
+    )
+    flexmock(module.os).should_receive('getpid').and_return(1234)
+    full_snapshot_name = 'dataset@borgmatic-1234'
+    flexmock(module).should_receive('snapshot_dataset').with_args(
+        '/usr/local/bin/zfs',
+        full_snapshot_name,
+    ).once()
+    snapshot_mount_path = '/run/borgmatic/zfs_snapshots/./mnt/dataset'
+    flexmock(module).should_receive('mount_snapshot').with_args(
+        '/usr/local/bin/mount',
+        full_snapshot_name,
+        module.os.path.normpath(snapshot_mount_path),
+    ).once()
+    source_directories = ['/mnt/dataset']
+    hook_config = {
+        'zfs_command': '/usr/local/bin/zfs',
+        'mount_command': '/usr/local/bin/mount',
+    }
+
+    assert (
+        module.dump_data_sources(
+            hook_config=hook_config,
+            config={
+                'source_directories': source_directories,
+                'zfs': hook_config,
+            },
+            log_prefix='test',
+            borgmatic_runtime_directory='/run/borgmatic',
+            source_directories=source_directories,
+            dry_run=False,
+        )
+        == []
+    )
+
+    assert source_directories == [snapshot_mount_path]
+
+
+def test_dump_data_sources_with_dry_run_skips_commands_and_does_not_touch_source_directories():
+    flexmock(module).should_receive('get_datasets_to_backup').and_return(
+        (('dataset', '/mnt/dataset'),)
+    )
+    flexmock(module.os).should_receive('getpid').and_return(1234)
+    flexmock(module).should_receive('snapshot_dataset').never()
+    flexmock(module).should_receive('mount_snapshot').never()
+    source_directories = ['/mnt/dataset']
+
+    assert (
+        module.dump_data_sources(
+            hook_config={},
+            config={'source_directories': '/mnt/dataset', 'zfs': {}},
+            log_prefix='test',
+            borgmatic_runtime_directory='/run/borgmatic',
+            source_directories=source_directories,
+            dry_run=True,
+        )
+        == []
+    )
+
+    assert source_directories == ['/mnt/dataset']
+
+
+def test_get_all_snapshots_parses_list_output():
+    flexmock(borgmatic.execute).should_receive('execute_command_and_capture_output').and_return(
+        'dataset1@borgmatic-1234\ndataset2@borgmatic-4567',
+    )
+
+    assert module.get_all_snapshots('zfs') == ('dataset1@borgmatic-1234', 'dataset2@borgmatic-4567')
+
+
+def test_remove_data_source_dumps_unmounts_and_destroys_snapshots():
+    flexmock(module).should_receive('get_all_datasets').and_return((('dataset', '/mnt/dataset'),))
+    flexmock(module.borgmatic.config.paths).should_receive(
+        'replace_temporary_subdirectory_with_glob'
+    ).and_return('/run/borgmatic')
+    flexmock(module.glob).should_receive('glob').replace_with(lambda path: [path])
+    flexmock(module.os.path).should_receive('isdir').and_return(True)
+    flexmock(module.shutil).should_receive('rmtree')
+    flexmock(module).should_receive('unmount_snapshot').with_args(
+        'umount', '/run/borgmatic/zfs_snapshots/mnt/dataset'
+    ).once()
+    flexmock(module).should_receive('get_all_snapshots').and_return(
+        ('dataset@borgmatic-1234', 'dataset@other', 'other@other', 'invalid')
+    )
+    flexmock(module).should_receive('destroy_snapshot').with_args(
+        'zfs', 'dataset@borgmatic-1234'
+    ).once()
+
+    module.remove_data_source_dumps(
+        hook_config={},
+        config={'source_directories': '/mnt/dataset', 'zfs': {}},
+        log_prefix='test',
+        borgmatic_runtime_directory='/run/borgmatic',
+        dry_run=False,
+    )
+
+
+def test_remove_data_source_dumps_use_custom_commands():
+    flexmock(module).should_receive('get_all_datasets').and_return((('dataset', '/mnt/dataset'),))
+    flexmock(module.borgmatic.config.paths).should_receive(
+        'replace_temporary_subdirectory_with_glob'
+    ).and_return('/run/borgmatic')
+    flexmock(module.glob).should_receive('glob').replace_with(lambda path: [path])
+    flexmock(module.os.path).should_receive('isdir').and_return(True)
+    flexmock(module.shutil).should_receive('rmtree')
+    flexmock(module).should_receive('unmount_snapshot').with_args(
+        '/usr/local/bin/umount', '/run/borgmatic/zfs_snapshots/mnt/dataset'
+    ).once()
+    flexmock(module).should_receive('get_all_snapshots').and_return(
+        ('dataset@borgmatic-1234', 'dataset@other', 'other@other', 'invalid')
+    )
+    flexmock(module).should_receive('destroy_snapshot').with_args(
+        '/usr/local/bin/zfs', 'dataset@borgmatic-1234'
+    ).once()
+    hook_config = {'zfs_command': '/usr/local/bin/zfs', 'umount_command': '/usr/local/bin/umount'}
+
+    module.remove_data_source_dumps(
+        hook_config=hook_config,
+        config={'source_directories': '/mnt/dataset', 'zfs': hook_config},
+        log_prefix='test',
+        borgmatic_runtime_directory='/run/borgmatic',
+        dry_run=False,
+    )
+
+
+def test_remove_data_source_dumps_bails_for_missing_zfs_command():
+    flexmock(module).should_receive('get_all_datasets').and_raise(FileNotFoundError)
+    flexmock(module.borgmatic.config.paths).should_receive(
+        'replace_temporary_subdirectory_with_glob'
+    ).never()
+    hook_config = {'zfs_command': 'wtf'}
+
+    module.remove_data_source_dumps(
+        hook_config=hook_config,
+        config={'source_directories': '/mnt/dataset', 'zfs': hook_config},
+        log_prefix='test',
+        borgmatic_runtime_directory='/run/borgmatic',
+        dry_run=False,
+    )
+
+
+def test_remove_data_source_dumps_bails_for_zfs_command_error():
+    flexmock(module).should_receive('get_all_datasets').and_raise(
+        module.subprocess.CalledProcessError(1, 'wtf')
+    )
+    flexmock(module.borgmatic.config.paths).should_receive(
+        'replace_temporary_subdirectory_with_glob'
+    ).never()
+    hook_config = {'zfs_command': 'wtf'}
+
+    module.remove_data_source_dumps(
+        hook_config=hook_config,
+        config={'source_directories': '/mnt/dataset', 'zfs': hook_config},
+        log_prefix='test',
+        borgmatic_runtime_directory='/run/borgmatic',
+        dry_run=False,
+    )
+
+
+def test_remove_data_source_dumps_skips_unmount_snapshot_directories_that_are_not_actually_directories():
+    flexmock(module).should_receive('get_all_datasets').and_return((('dataset', '/mnt/dataset'),))
+    flexmock(module.borgmatic.config.paths).should_receive(
+        'replace_temporary_subdirectory_with_glob'
+    ).and_return('/run/borgmatic')
+    flexmock(module.glob).should_receive('glob').replace_with(lambda path: [path])
+    flexmock(module.os.path).should_receive('isdir').and_return(False)
+    flexmock(module.shutil).should_receive('rmtree').never()
+    flexmock(module).should_receive('unmount_snapshot').never()
+    flexmock(module).should_receive('get_all_snapshots').and_return(
+        ('dataset@borgmatic-1234', 'dataset@other', 'other@other', 'invalid')
+    )
+    flexmock(module).should_receive('destroy_snapshot').with_args(
+        'zfs', 'dataset@borgmatic-1234'
+    ).once()
+
+    module.remove_data_source_dumps(
+        hook_config={},
+        config={'source_directories': '/mnt/dataset', 'zfs': {}},
+        log_prefix='test',
+        borgmatic_runtime_directory='/run/borgmatic',
+        dry_run=False,
+    )
+
+
+def test_remove_data_source_dumps_skips_unmount_snapshot_mount_paths_that_are_not_actually_directories():
+    flexmock(module).should_receive('get_all_datasets').and_return((('dataset', '/mnt/dataset'),))
+    flexmock(module.borgmatic.config.paths).should_receive(
+        'replace_temporary_subdirectory_with_glob'
+    ).and_return('/run/borgmatic')
+    flexmock(module.glob).should_receive('glob').replace_with(lambda path: [path])
+    flexmock(module.os.path).should_receive('isdir').with_args(
+        '/run/borgmatic/zfs_snapshots'
+    ).and_return(True)
+    flexmock(module.os.path).should_receive('isdir').with_args(
+        '/run/borgmatic/zfs_snapshots/mnt/dataset'
+    ).and_return(False)
+    flexmock(module.shutil).should_receive('rmtree')
+    flexmock(module).should_receive('unmount_snapshot').never()
+    flexmock(module).should_receive('get_all_snapshots').and_return(
+        ('dataset@borgmatic-1234', 'dataset@other', 'other@other', 'invalid')
+    )
+    flexmock(module).should_receive('destroy_snapshot').with_args(
+        'zfs', 'dataset@borgmatic-1234'
+    ).once()
+
+    module.remove_data_source_dumps(
+        hook_config={},
+        config={'source_directories': '/mnt/dataset', 'zfs': {}},
+        log_prefix='test',
+        borgmatic_runtime_directory='/run/borgmatic',
+        dry_run=False,
+    )
+
+
+def test_remove_data_source_dumps_with_dry_run_skips_unmount_and_destroy():
+    flexmock(module).should_receive('get_all_datasets').and_return((('dataset', '/mnt/dataset'),))
+    flexmock(module.borgmatic.config.paths).should_receive(
+        'replace_temporary_subdirectory_with_glob'
+    ).and_return('/run/borgmatic')
+    flexmock(module.glob).should_receive('glob').replace_with(lambda path: [path])
+    flexmock(module.os.path).should_receive('isdir').and_return(True)
+    flexmock(module.shutil).should_receive('rmtree').never()
+    flexmock(module).should_receive('unmount_snapshot').never()
+    flexmock(module).should_receive('get_all_snapshots').and_return(
+        ('dataset@borgmatic-1234', 'dataset@other', 'other@other', 'invalid')
+    )
+    flexmock(module).should_receive('destroy_snapshot').never()
+
+    module.remove_data_source_dumps(
+        hook_config={},
+        config={'source_directories': '/mnt/dataset', 'zfs': {}},
+        log_prefix='test',
+        borgmatic_runtime_directory='/run/borgmatic',
+        dry_run=True,
+    )