Skip to content

Add 'set_task_metadata', associated test, and example in README #56

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 9 commits into from
Oct 7, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions README.rst
Original file line number Diff line number Diff line change
Expand Up @@ -271,6 +271,24 @@ __ https://docs.scale.com/reference/delete-task-unique-id
task.clear_unique_id()


Set A Task's Metadata
^^^^^^^^^^^^^^^^^^^^^^^^^

Set a given task's ``metadata``. Check out `Scale's API documentation`__ for more information.

__ https://docs.scale.com/reference/set-metadata

.. code-block :: python

# set metadata on a task by specifying task id
new_metadata = {'myKey': 'myValue'}
task = client.set_task_metadata('30553edd0b6a93f8f05f0fee', new_metadata)

# set metadata on a task object
task = client.get_task('30553edd0b6a93f8f05f0fee')
new_metadata = {'myKey': 'myValue'}
task.set_metadata(new_metadata)

Batches
_______

Expand Down
15 changes: 15 additions & 0 deletions scaleapi/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -114,6 +114,21 @@ def clear_task_unique_id(self, task_id: str) -> Task:
endpoint = f"task/{task_id}/unique_id"
return Task(self.api.delete_request(endpoint), self)

def set_task_metadata(self, task_id: str, metadata: Dict) -> Task:
"""Sets a task's metadata and returns the associated task.

Args:
task_id (str):
Task id
metadata (Dict):
metadata to set

Returns:
Task
"""
endpoint = f"task/{task_id}/setMetadata"
return Task(self.api.post_request(endpoint, body=metadata), self)

def tasks(self, **kwargs) -> Tasklist:
"""Returns a list of your tasks.
Returns up to 100 at a time, to get more, use the
Expand Down
2 changes: 1 addition & 1 deletion scaleapi/_version.py
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
__version__ = "2.9.0"
__version__ = "2.10.0"
__package_name__ = "scaleapi"
4 changes: 4 additions & 0 deletions scaleapi/tasks.py
Original file line number Diff line number Diff line change
Expand Up @@ -95,3 +95,7 @@ def update_unique_id(self, unique_id: str):
def clear_unique_id(self):
"""Clears unique_id of a task"""
self._client.clear_task_unique_id(self.id)

def set_metadata(self, metadata: dict):
"""Sets the metadata of a task"""
self._client.set_task_metadata(self.id, metadata)
20 changes: 19 additions & 1 deletion tests/test_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,25 @@ def test_clear_unique_id():
assert "unique_id" not in task.as_dict()


def test_set_metadata():
unique_id = str(uuid.uuid4())
original_task = make_a_task(unique_id)
new_metadata = {"myKey": "myValue"}
updated_task = client.set_task_metadata(original_task.id, new_metadata)
assert original_task.metadata == {}
assert updated_task.metadata == new_metadata


def test_task_set_metadata():
unique_id = str(uuid.uuid4())
task = make_a_task(unique_id)
assert task.metadata == {}
new_metadata = {"fromTaskKey": "fromTaskValue"}
task.set_metadata(new_metadata)
task.refresh()
assert task.metadata == new_metadata


def test_categorize_ok():
client.create_task(
TaskType.Categorization,
Expand Down Expand Up @@ -169,7 +188,6 @@ def test_imageannotation_fail():
def test_documenttranscription_ok():
client.create_task(
TaskType.DocumentTranscription,
callback_url="http://www.example.com/callback",
instruction="Please transcribe this receipt.",
attachment="http://document.scale.com/receipt-20200519.jpg",
features=[{"type": "block", "label": "barcode"}],
Expand Down