/usr/lib/rads/venv/lib/python3.13/site-packages/restic/__pycache__
Edit: /usr/lib/rads/venv/lib/python3.13/site-packages/restic/__pycache__/base.cpython-313.pyc (30698B)
j_ n S r SSKJrJrJr SSKJr SSKJrJ r SSK
r
SSK J r
SSKrSSKJrJr SSKrSSKrSSKJr SS KJrJr SS
KJr SSK r S S K J r J r J!r!J"r"J#r#J$r$ S S
K J%r%J&r&J'r'J(r( S SK J)r)J*r* S SK+J,r,J-r-J.r. \ " S5 R_ 5 ( a Sr0OSr0S r1 " S S5 r2 " S S5 r3g)z!Main Restic objects and functions )LiteralTextIOoverload) Generator)PurePathPathN)quote)CalledProcessErrorPIPE)Config)
BotoCoreError ClientError)ServiceResource )
ResticRepoSnapshot ResticCmdSnapPathSnapFileSnapDir)BackupSQLBackupGroup
SQLBackupItemUserBackupDicts) UserBackups
_tag_quote) ResticErrorResticBadIndexErrorResticLockedErrorz/usr/bin/imh-resticz/usr/bin/resticc F ^ [ R " T 5 U 4S j5 nU$ )zFWraps a function and makes it automatically retry on ResticLockedErrorc > T" U /UQ70 UD6$ ! [ a nUR 5 ( d e S nAOS nAff = fU R 5 T" U /UQ70 UD6$ N)r unlock_okunlock)selfargskwargsexcfuncs >/usr/lib/rads/venv/lib/python3.13/site-packages/restic/base.py
_locked_retry#locked_retry.
._locked_retry s` .t.v. . ==?? #
D*4*6**s
949) functoolswraps)r) r+ s ` r* locked_retryr/ s( __T+ + c \ rS rSrSrSrSSSSSS.S \S
\S- S \S \\- \ R - S- S
\ \- S\ \- S- S\S- 4S jjr S r
\S\\\4 4S j5 rSGS\4S jjrS\S- 4S jrS\4S jrS\4S jrS r\S 5 r\SHS\4S jj5 rS\4S jr \S\ \ 4S j5 r \SSS .S \ \ S- S!\\- S- S\ \ 4S" jj5 r SSSSS#.S$\ \\ - S \ \ S%\S- S&\ \\ - S- S'\ \\ - S- S(\S\4S) jjr! SIS*\\ - S \ \ S%\S- S(\S+\\"- SS4 S, jjr# SIS*\\ - S \ \ S%\S- S(\S\4
S- jjr$S.\ \- S/\\ - S\4S0 jr%SSS1S2.S.\ \- S3\ \\ - S- S&\ \\ - S- S4\\ - S\4
S5 jjr&\'S \ \ S%\S- S(\S\ \ 4S6 j5 r(\S7SS8.S9\S\4S: jj5 r)S.\ \- S*\\ - S\ \*\+- 4S; jr,\S.\ \- S*\\ - S\-\*\+- SS4 4S< j5 r.\/ SJSSS=.S>\S- S!\\- S- S?\0S S@\ \ S- S\\\14 4
SA jjj5 r2\/ SJSSS=.S>\S- S!\\- S- S?\0S7 S@\ \ S- S\\\34 4
SB jjj5 r2 SJSSSSC.S>\S- S!\\- S- S?\S@\ \ S- S\\\\\ 4 4 4
SD jjjr2\'SE 5 r4SFr5g)KRestic- a Handles restic commands
Args:
endpoint (str): S3 server base url with https:// (excluding s3: prefix)
cluster (str | None): Optional cluster name. Only used by repr()
repo (ResticRepo): dataclass containing bucket name and key info
lim (int, float, ProcLimit, None): max load limit. This can be a static
limit if you set it to a float or int, or for more flexibility,
use a ``ProcLimit`` instance. If unset, processes will not be
ratelimited
tmp_dir (Path | str): TMPDIR to use. Defaults to '/var/tmp/restic'.
cache_dir (Path, str | None): RESTIC_CACHE_DIR to use. Set this to
None to disable cache. Defaults to '/var/cache/restic/%(bucket)s'
gomaxprocs (int, None): max CPU cores to allow restic to use
resticNz/var/tmp/resticz /var/cache/restic/%(bucket)s )clusterlimtmp_dir cache_dir
gomaxprocsendpointr6 repor7 r8 r9 r: c Xl X l X0l X@l [ U5 U l Xpl Uc S U l O [ U5 SUR 0- U l U R U l
g )Nbucket) r; r6 r< r7 strr8 r: r9 r> repair_index
rebuild_index)r% r; r6 r< r7 r8 r9 r: s r* __init__Restic.__init__@ s\ !
7| $ !DN ^x.E EDN ! . .r0 c U R ( a' SU R SU R R S3$ SU R R S3$ )NzRestic<:>)r6 r< r> )r% s r* __repr__Restic.__repr__W sG << T\\N!DII,<,<+=Q? ?))*!,,r0 returnc L U R SU R R U R R U R R S.nU R
( a U R
US' U R b( U R S: a [ U R 5 US' U$ )z Restic environment variable dict1)TMPDIRGOGCRESTIC_PASSWORDAWS_ACCESS_KEY_IDAWS_SECRET_ACCESS_KEYRESTIC_CACHE_DIRr
GOMAXPROCS)r8 r< restic_pass
access_key
secret_keyr9 r: r? )r% rets r* env
Restic.env\ s ll #yy 4 4!%!5!5%)YY%9%9
>>&*nnC" # ?? &4??Q+> #DOO 4C
r0 c [ USU0US9n[ R " SU R U R R
U R R US9R U R R 5 $ )zGets a boto3 s3.Bucket for this repo
Args:
timeout (int): network timeout in secs
retries (int): times to retry on timeout
Returns:
s3.Bucket: boto3 resource for this bucket
max_attempts)connect_timeoutretries read_timeouts3) endpoint_urlaws_access_key_idaws_secret_access_keyconfig)
BotoConfigboto3resourcer; r< rT rU Bucketr> )r% timeoutr\ rb s r* s3_bucketRestic.s3_bucketl sl ##W-
~~ "ii 2 2"&))"6"6
&!!
"
#r0 c [ [ U R 5 R R SS95 5 S: $ ! [
a nS[
U5 ; a SnAge SnAff = f)a@ Check if the /keys/ path has items in it, meaning that restic
has been initialized
Raises:
botocore.exceptions.ClientError: connection problem
botocore.exceptions.BotoCoreError: boto3 error
Returns:
(bool | None): whether the keys path existed in the bucket, or
None if the bucket did not exist at all
zkeys/)Prefixr NoSuchBucketN)lenlistrh objectsfilterr r? r% r( s r* init_key_existsRestic.init_key_exists s] D )11888HIJQN
S) s ;>
A"A A A"c U R 5 U R 5 g! [ [ 4 a6 n[ R " SU [ U5 R U5 SnAgSnAf[ ak nUR 5 ( d' [ R " SUR U5 SnAg U R 5 SnAN! [ a SnANf = fSnAf[ a/ n U R 5 SnAN! [ a SnANf = fSnAf[ a, n[ R " SUR U5 SnAgSnAff = f! [ [ 4 a6 n[ R " SU [ U5 R U5 SnAgSnAf[ a, n[ R " SUR U5 SnAgSnAff = f)zPrepare access to this repo if needed and preemptively fix
issues connecting to it. Plugins should probably run this first
Returns:
bool: whether this repo is ready for access
z %s %s: %sNFz%%s: could not automatically unlock
%sz%s: %sT) init_repor
r loggingerrortype__name__r r# namer$ r r rA rq s r* prepareRestic.prepare sO NN , NN ; {+ MM+tT#Y-?-? E ==??
rV s r* ru Restic.init_repo s ))+ +6 + >^^%F MMO $ $ &jj $$D$> CJJ . &cjj 8 c" "r0 c U R S5 R SSS9 g! [ a n[ U5 UeSnAff = f)zORun restic unlock
Raises:
ResticError: if the restic unlock command fails
r$ Tcheckr Nr r r
r rq s r* r$
Restic.unlock s@ , JJx $ $4 $ =! , c" + ,s "
= 8=c U R SSS5 R SSS9 g! [ a n[ U5 UeSnAff = f)zGRun restic repair index
Raises:
ResticError: if the command fails
repairindexz--read-all-packsTr Nr rq s r* r@ Restic.repair_index sM , JJx*< = A A4
B
" , c" + ,s !$
? :?Tr c U R ( a SnOSn U R " U6 R SUS9 g! [ a n[ U5 UeSnAff = f)zRun restic prune
Args:
no_lim (bool): do not CPU limit the command as it runs regardless
of the lim arg in Restic
Raises:
ResticError: if the command fails
)prune--cleanup-cache)r Tr N)r9 r r r
r )r% r r& r( s r* r Restic.prune sS >>/D D , JJ ! !V ! <! , c" + ,s 6
A A Ac N U R nUR U5 [ X S9$ )zBuild a ResticCmd object that can be used to execute the requested
restic command
Args:
*args (tuple[str]): restic subcommand and args
Returns:
ResticCmd: a restic command executor
)r4 )_basecmdextendr )r% r& cmds r* r Restic.build s$ mm
4**r0 c [ SU R SU R R 3/nU R ( d UR S5 U$ )Nz
--repo=s3:/z
--no-cache) RESTIC_PATHr; r< r> r9 append)r% r s r* r Restic._basecmd sG
q)9)9(: ;
~~ JJ| $
r0 tagsrg r rg c j SS/nU( a* U H$ nUR S[ U[ 5 /5 M& U R " U6 R [
SSUS9n[ R " UR 5 Vs/ s H n[ XS9PM sn$ ! [ a n[ U5 UeSnAff = fs snf )a} Get a list of restic snapshots in this repo. If this server is a
Backup Manager client, see the ``get_backups()`` function instead
args:
tags (list[str], optional): only consider snapshots which include
this tag list. To check with AND logic, specify a single tag as
``["tag1,tag2"]``. To check for either tag, specify
independently as ``["tag1", "tag2"]``
timeout (float | int | None): optional command timeout
Raises:
ResticError: if the restic snapshots command failed
subprocess.TimeoutExpired: if timeout was specified and exceeded
Returns:
list[Snapshot]: Snapshots found in the repo
snapshots--json--tagT)r r r rg Nr4 data) r r url_quoter r r r
r jsonloadsr r )r% r rg r& tagrV r( xs r* r Restic.snapshots s 0 X& Wji&@ AB ,**d#''4g ( C
8?zz4 r0 snapfilenamec [ U[ 5 ( a UR OUnU R SU[ U5 5 $ )zCrafts a ResticCmd to dump a file from the specified snapshot ID
Args:
snap (Snapshot | str): snapshot or snapshot ID to dump data from
filename (str | PurePath): filename to retrieve
Returns:
ResticCmd: restic command executor
dump)r r idr r? )r% r r snap_ids r* r Restic.dump s2 (h 7 7$''Tzz&'3x=99r0 r )includesr targetr r c D [ U[ 5 ( a UR OUnSS[ U5 /nUb% U H nUR S[ U5 /5 M! Ub% U H nUR S[ U5 /5 M! UR U5 U R " U6 $ )a Crafts a ResticCmd to restore a snapshot
Args:
snap (str): snapshot or snapshot ID to restore from
includes (list[str | PurePath], optional): --include paths
excludes (list[str | PurePath], optional): --exclude paths
target (str | PurePath): base directory prefix to restore to.
Defaults to '/', which restores to the original path
Returns:
ResticCmd: restic command executor
restorez--targetz --includer )r r r r? r r r ) r% r r r r r r& includer s r* r Restic.restore s ( (h 7 7$''T:s6{3 # [#g, 78 $ # [#g, 78 $ G zz4 r0 c S/nU( a UR S5 Ub" US: a UR S[ U5 /5 U H$ nUR S[ U[ 5 /5 M& U$ )z!Builds the base backup subcommandr z--quietr z--limit-uploadr )r r r? r r )r r r r& r s r* r Restic._backup_args sc
z KK " 7Q; KK)3w<8 9C KK*S)"<= > r0 F)r r r c S/nU( a6 U R ( a UR SS/5 OUR S5 UR U Vs/ s H& n[ U[ 5 ( a UR
OUPM( sn5 U R " U6 R SUS9 gs snf ! [ a n[ U5 UeSnAff = f)a Run restic forget
Args:
*ids (Snapshot | str): snapshots to remove, specified by
either a Snapshot object or snapshot ID str
prune (bool): whether to automatically run prune if at
least one snapshot was removed. Defaults to False
no_lim (bool): do not CPU limit the command as it runs regardless
of the lim arg in Restic
Raises:
ResticError: if the restic forget command fails
forgetz--pruner Tr N)
r9 r r r r r r r r
r )r% r r idsr& r r( s r* r
Restic.forget s z ~~ Y(9 :; I& SISZ8 4 4QTT!;SIJ , JJ ! !V ! < J " , c" + ,s -B# B( (
C2 B>>Cc 2 [ U R XS95 $ )a
Like ``scandir`` but return a list instead of a Generator.
Returns files/dirs found in a requested path in a Snapshot
Args:
snap (Snapshot | str): snapshot to list the contents of, supplied
either by its Snapshot instance of snapshot ID
path (str | PurePath): full path inside the snapshot to list the
contents of
Raises:
ValueError: requested path was not a full path
ResticError: Any error listing snapshot contents from restic
Returns:
list[SnapFile | SnapDir]: files or directories
)r r )rn scandir)r% r r s r* listdirRestic.listdir s & DLLdL677r0 c # # [ U[ 5 ( a UR OUn[ U5 nUR S5 ( d [ S5 eUR
S5 nUS:X a SnU R SSSX25 n UR [ SSS9R R 5 n[ U5 S
: a g [ U [ R " UR# S 5 5 S 9nU( aq [ R " UR# S 5 5 n[% UU US
US US US US UR' SS 5 UR' SS 5 S9 v U( a Mp g g ! [ a n[ U5 UeS nAff = f7f)a Iterates over files/dirs found in a requested path in a Snapshot
Args:
snap (Snapshot | str): snapshot to list the contents of, supplied
either by its Snapshot instance of snapshot ID
path (str | PurePath): full path inside the snapshot to list the
contents of
Raises:
ValueError: requested path was not a full path
ResticError: Any error listing snapshot contents from restic
Yields:
Generator[SnapFile | SnapDir, None, None]: files or directories
r zpath must be a full path lsr z--longT)r r r Nr5 r r rz rx r uidgidmode permissions) snapshotr4 rz rx r r r r r )r r r r?
startswith
ValueErrorrstripr r r r
splitlinesr
r rm r r popr get) r% r r r r linesr( r r s r* r Restic.scandir sZ & (h 7 7$''T4ys## 78 8{{3 2:Djjx7A ,GG4 fZZ\
u:> 4djj1 .FG::eiil+D!&\&\&\KKXXfd+ HH]D 9
e
" , c" + ,s1 A=F -E# -B2F!F#
E>- E99E>>F)rg r user serializer c g r" r% r rg r r s r* get_backupsRestic.get_backupsC s &)r0 c g r" r r s r* r r M s "%r0 )rg r r c Uc SOSU 3nU( a; UR 5 nU( a# U Vs/ s H ouUR ; d M UPM nnOU R Uc SOU/US9n0 n/ n 0 n
U( Ga [ UR 5 5 n [ U [ 5 ( a U R U 5 OU R U; a 0 XR ' U R XR ; a / XR U R ' XR U R R U 5 [ U [ 5 ( a% XU R U R U R 4' U( a GM U HH n U R U R U R 4n X; d M- XU R U R ' MJ U( a U R! U5 U$ s snf ! [
[ 4 a GM f = f)a Get backups for a backups 3.x Backup Manager client
Args:
user (str, optional): only list backups found for this user
timeout (int | float | None): timeout for the underlying
restic snapshots command
serialize (bool): if True, return as a json-serializable dict. If
False, return as Backup, SQLBackupGroup, and SQLBackupItem
objects
snapshots (list[Snapshot], optional): if provided, scan the backups
found in this list rather than executing ``restic snapshots``
Returns:
dict[str, dict[str, list]]: Top-level keys are usernames.
Second-level are the type of backup. Values are a list of backups
found which may be dicts or objects depending on the serialize arg
Nzuser:r )copyr r r r r KeyErrorr r r r rx r timedbsdbnamer )
r% r rg r r r all_snapsr outsqlssql_mapbakkeys
r* r r W s 2 ld%v !(I(1 C 1AFF]Q C !\Tu ' I
Y]]_- #}-- C 883&$&CM883xx=0.0CM#((+HH
chh'..s3 c>22>ASXXsxx :; i C88SXXsxx0C~/2 , NN3
A D )
s G G 2G" "G76G7c U HC nX R 5 H* u p#U Vs/ s H oDR 5 PM snX U' M, ME gs snf )zOConverts the return of get_backups(serialize=False) to a
json-serializable dictN)itemsr )backupsr bak_typeobjsr s r* r Restic.serialize sG D")-"5"5"7BF*G$Q;;=$*G
h' #8 *Gs A )r9 r6 r; r: r7 rA r< r8 ) r5 )T)NTr" )6ry
__module__ __qualname____firstlineno____doc__r? r intfloatcproc ProcLimitr rB rG propertydictrW S3Bucketrh boolrr r{ ru r$ r/ r@ r r r rn r r r r r r r r r staticmethodr r r r r r r r r r r r r __static_attributes__r r0 r* r2 r2 - s J #48"3+I!"/ / t /
/ 5[5??
*T
1
/ C / c>D(/ $J/.-
T#s(^
#( #. *& &P4 0 , , , ,D , ,& +i + $s) "&&* !O 3i$ !O ut# !O
h !O !OP #0459%!C(N#%! 3i %!
t %! sX~&-
%! C(N+d2%! %!
%!Z # , Hn ,
3i , t
, ,f ,
,L # !Hn! 3i! t !
!
!2 :C :3> :i :" 1504!$
!n ! sX~&- !
sX~&- ! h
!
!> 3i "%* 59
c ).t ,$ , , ,48 sN8*-.8
h !8* 0 sN0*-.0 8g%tT1 20 0d ) '++/
)Dj) ut# )
4= ) >D(
)
c?" #) ) % '++/
%Dj% ut# %
5> % >D(
%
c; % % = '+ +/
=Dj= ut# =
= >D(
=
c4T ?" #=~ H Hr0 r2 c X \ rS rSrSrS\4S jrS\S\4S jrS\4S jr S\S\4S
jr
S r g )
S3Tooli zWrapper object for moving items around in an S3 Bucket
Args:
s3_bucket (S3Bucket): service resource from ``Restic.s3_bucket()``
rh c / U l Xl g r" )movedr> )r% rh s r* rB S3Tool.__init__ s
r0 srcdestc h U R R U R R US.U5 $ )z Copy an item in the S3 bucket)rf Key)r> r rz r% r r s r* r S3Tool.copy s( {{ 4;;+;+;C H$OOr0 r c h U R R U R R SSU0/0S9$ )z Delete an item in the S3 bucketObjectsr )rf Delete)r> delete_objectsrz )r% r s r* delete
S3Tool.delete s8 {{));;##Y% ,G *
r0 c ~ U R X5 U R U5 U R R U5 g)z Move an item in the S3 bucketN)r r$ r r r s r* move S3Tool.move s, # C
$ r0 )r> r N) ry r r r r
r rB r? r r$ r' r r r0 r* r r sH ( P P3 P
#
3 r0 r )4r
typingr r r collections.abcr pathlibr r r urllib.parser r r-
subprocessr
r rv rd botocore.clientr rc botocore.exceptionsr
r boto3.resources.baser r r
r r r r r r r r r r r r r r( r r r r r r/ r2 r r r0 r* r1 s ' , , % " + / 0 : < N N H H ) D D %%'''K#K
o H o Hd r0