| 199 | @with_connection |
| 200 | @with_s3_exception_handler |
| 201 | def __start_folder_fetch(self, opts): |
| 202 | |
| 203 | spec_list = [{'bucket_name': str, 'path': str}] |
| 204 | log = regular_log.default() |
| 205 | log, input = regular_input.input_check_many(untrusted_input = opts, |
| 206 | spec_list = spec_list, |
| 207 | log = log) |
| 208 | if len(log["error"].keys()) >= 1: |
| 209 | return {'log': log} |
| 210 | t = threading.Thread( |
| 211 | target = self.__fetch_folder, |
| 212 | args = ((opts,))) |
| 213 | t.start() |
| 214 | return {'result': True} |
| 215 | |
| 216 | @with_connection |
| 217 | @with_s3_exception_handler |