|
|
@@ -1,6 +1,5 @@ |
|
|
|
#!/usr/bin/env python |
|
|
|
import base64 |
|
|
|
import copy |
|
|
|
import datetime |
|
|
|
import json |
|
|
|
import os |
|
|
@@ -38,7 +37,8 @@ def watch_pass(input_directory: pathlib.Path, work_directory: pathlib.Path, ia_c |
|
|
|
original_directory.rename(new_directory) |
|
|
|
except FileNotFoundError: |
|
|
|
logging.warning(f"Unable to move item {original_directory}") |
|
|
|
single_impl(new_directory, ia_collection, ia_item_title, ia_item_prefix, ia_item_date, project, dispatcher, |
|
|
|
single_impl(new_directory, ia_collection, ia_item_title, ia_item_prefix, ia_item_date, project, |
|
|
|
dispatcher, |
|
|
|
delete, backfeed_key) |
|
|
|
return True |
|
|
|
finally: |
|
|
@@ -181,7 +181,7 @@ def single_impl(item_directory: pathlib.Path, ia_collection: str, ia_item_title: |
|
|
|
logging.exception("Failed to upload") |
|
|
|
time.sleep(30) |
|
|
|
|
|
|
|
item_data = { "url": url, "item_name": item_directory.name, "bucket_name": bucket_name } |
|
|
|
item_data = {"url": url, "item_name": item_directory.name, "bucket_name": bucket_name} |
|
|
|
bf_item_part = base64.urlsafe_b64encode(str(json.dumps(item_data)).encode("UTF-8")).decode("UTF-8") |
|
|
|
bf_item = f"{project}:{parsed_url.hostname}:{bf_item_part}" |
|
|
|
else: |
|
|
|