Skip to content

Commit

Permalink
added x_tile and y_tile to engine.py s3 put metadata, which is needed…
Browse files Browse the repository at this point in the history
… by the ingest_lambda on the backend to handle corrupt tiles.

Fixed a misleading argument tag in debug.py
Updated version and change log to reflect the changes
  • Loading branch information
sandyhider committed Jul 18, 2018
1 parent 64b054b commit 40f065f
Show file tree
Hide file tree
Showing 4 changed files with 13 additions and 3 deletions.
7 changes: 7 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,12 @@
# Boss Ingest Client Changelog

## 0.9.10

### Fixed Bug:

* Added x and y tile sizes to metadata of s3 tiles. This allows the ingest backend to create blank tiles when corrupt images are received.


## 0.9.9

### Fixed Bug:
Expand Down
2 changes: 1 addition & 1 deletion debug.py
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ def main():
epilog="Visit https://docs.theBoss.io for more details")

parser.add_argument("queue_name",
help="Name of the ingest SQS queue")
help="URL of the ingest SQS queue")

parser.add_argument("data_dir",
default=None,
Expand Down
2 changes: 1 addition & 1 deletion ingestclient/__init__.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
__version__ = '0.9.9'
__version__ = '0.9.10'


def check_version():
Expand Down
5 changes: 4 additions & 1 deletion ingestclient/core/engine.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,6 @@
from .config import Configuration, ConfigFileError
from collections import deque


class Engine(object):
def __init__(self, config_file=None, backend_api_token=None, ingest_job_id=None, configuration=None):
"""
Expand Down Expand Up @@ -341,9 +340,13 @@ def run(self):
key_parts["t_index"])

try:
print("x_tile_size: " + str(self.config.config_data['ingest_job']["tile_size"]["x"]))
print("x_tile_size: " + str(self.config.config_data['ingest_job']["tile_size"]["x"]))
metadata = {'chunk_key': msg['chunk_key'],
'ingest_job': self.ingest_job_id,
'parameters': self.job_params,
'x_size': self.config.config_data['ingest_job']["tile_size"]["x"],
'y_size': self.config.config_data['ingest_job']["tile_size"]["y"],
}
handle.seek(0)
response = self.backend.bucket.put_object(ACL='private',
Expand Down

0 comments on commit 40f065f

Please sign in to comment.