1818
1919display = Display ()
2020
21+
2122def tmp_file_factory (prefix ):
2223 def outer (func ):
2324 def inner (self , * args , ** kwargs ):
@@ -44,17 +45,19 @@ def inner(self, *args, **kwargs):
4445 del func .__globals__ [f"{ prefix } _fp" ]
4546 else :
4647 func .__globals__ [f"{ prefix } _fp" ] = cached_fp
48+
4749 return inner
50+
4851 return outer
4952
53+
5054class ActionModule (ActionBase ):
5155
5256 TRANSFERS_FILES = True
5357
5458 def __init__ (self , * args , ** kwargs ):
5559 super (ActionModule , self ).__init__ (* args , ** kwargs )
5660
57-
5861 @tmp_file_factory ("fetched" )
5962 @tmp_file_factory ("rendered" )
6063 def run (self , tmp = None , task_vars = None ):
@@ -82,26 +85,23 @@ def run(self, tmp=None, task_vars=None):
8285 self ._rendered_real_file = rendered_fp
8386 template_result = self ._execute_module (
8487 module_name = "ansible.builtin.template" ,
85- module_args = {
86- "dest" : self ._rendered_real_file ,
87- "src" : self ._src_real_file
88- },
88+ module_args = {"dest" : self ._rendered_real_file , "src" : self ._src_real_file },
8989 task_vars = task_vars ,
9090 )
9191 self ._rendered_checksum = checksum (self ._rendered_real_file )
9292
93- display .vv ("The rendered (if applicable) source file %s checksum is %s" % (self ._rendered_real_file , self ._rendered_checksum ))
93+ display .vv (
94+ "The rendered (if applicable) source file %s checksum is %s"
95+ % (self ._rendered_real_file , self ._rendered_checksum )
96+ )
9497
9598 try :
96- self ._connection ._ssh_type_conn .fetch_file (
97- self ._dest ,
98- fetched_fp ,
99- self ._protocol
100- )
99+ self ._connection ._ssh_type_conn .fetch_file (self ._dest , fetched_fp , self ._protocol )
101100 except Exception as exc :
102101 if not (
103- "Error receiving information about file" in exc .message and
104- "No such file or directory" in exc .message ):
102+ "Error receiving information about file" in exc .message
103+ and "No such file or directory" in exc .message
104+ ):
105105 raise exc
106106 display .vv ("The file is not present on the remote device" )
107107 finally :
@@ -111,12 +111,9 @@ def run(self, tmp=None, task_vars=None):
111111 try :
112112 if self ._dest_checksum != self ._rendered_checksum :
113113 self ._connection ._ssh_type_conn .put_file (
114- self ._loader .get_real_file (self ._rendered_real_file ),
115- self ._dest ,
116- self ._protocol
114+ self ._loader .get_real_file (self ._rendered_real_file ), self ._dest , self ._protocol
117115 )
118116 finally :
119117 self ._connection ._ssh_type_conn .reset ()
120118
121119 return result
122-
0 commit comments