|
48 | 48 |
|
49 | 49 | import pyclowder.datasets |
50 | 50 | import pyclowder.files |
51 | | -import pyclowder.api.v1.files as v1files |
52 | | -import pyclowder.api.v2.files as v2files |
53 | 51 | import pyclowder.utils |
54 | 52 |
|
55 | 53 | import smtplib |
@@ -441,18 +439,10 @@ def _process_message(self, body): |
441 | 439 | found_local = False |
442 | 440 | try: |
443 | 441 | if check_result != pyclowder.utils.CheckMessage.bypass: |
444 | | - if clowder_version == 2.0: |
445 | | - file_metadata = v2files.download_info(self, host, secret_key, resource["id"]) |
446 | | - else: |
447 | | - file_metadata = v1files.download_info(self, host, secret_key, resource["id"]) |
| 442 | + file_metadata = pyclowder.files.download_info(self, host, secret_key, resource["id"]) |
448 | 443 | file_path = self._check_for_local_file(file_metadata) |
449 | 444 | if not file_path: |
450 | | - if clowder_version == 2.0: |
451 | | - file_path = v2files.download(self, host, secret_key, resource["id"], |
452 | | - resource["intermediate_id"], |
453 | | - resource["file_ext"]) |
454 | | - else: |
455 | | - file_path = v1files.download(self, host, secret_key, resource["id"], |
| 445 | + file_path = pyclowder.files.download(self, host, secret_key, resource["id"], |
456 | 446 | resource["intermediate_id"], |
457 | 447 | resource["file_ext"]) |
458 | 448 | else: |
|
0 commit comments