Skip to content

Commit dc7d985

Browse files
committed
CR changes
1 parent 3b065b8 commit dc7d985

File tree

4 files changed

+37
-35
lines changed

4 files changed

+37
-35
lines changed

labelbox/schema/export_params.py

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
import sys
2+
3+
from typing import Optional
4+
if sys.version_info >= (3, 8):
5+
from typing import TypedDict
6+
else:
7+
from typing_extensions import TypedDict
8+
9+
10+
class DataRowParams(TypedDict):
11+
include_data_row_details: Optional[bool]
12+
include_media_attributes: Optional[bool]
13+
include_metadata_fields: Optional[bool]
14+
include_attachments: Optional[bool]
15+
16+
17+
class ProjectExportParams(DataRowParams):
18+
include_project_details: Optional[bool]
19+
include_label_details: Optional[bool]
20+
include_performance_details: Optional[bool]
21+
22+
23+
class ModelRunExportParams(DataRowParams):
24+
# TODO: Add model run fields
25+
pass

labelbox/schema/filters.py

Lines changed: 0 additions & 25 deletions
This file was deleted.

labelbox/schema/model_run.py

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
from labelbox.orm.query import results_query_part
1313
from labelbox.orm.model import Field, Relationship, Entity
1414
from labelbox.orm.db_object import DbObject, experimental
15-
from labelbox.schema.filters import ModelRunExportFilter
15+
from labelbox.schema.export_params import ModelRunExportParams
1616
from labelbox.schema.task import Task
1717
from labelbox.schema.user import User # type: ignore
1818

@@ -457,7 +457,8 @@ def export_labels(
457457
"""
458458

459459
def export_labels_v2(self, task_name: str,
460-
filter: Optional[ModelRunExportFilter]) -> Task:
460+
params: Optional[ModelRunExportParams]) -> Task:
461+
_params = params or {}
461462
mutation_name = "exportDataRows"
462463
create_task_query_str = """mutation exportDataRowsPyApi($input: ExportDataRowsInput!){
463464
%s(input: $input) {taskId} }
@@ -471,14 +472,13 @@ def export_labels_v2(self, task_name: str,
471472
},
472473
"params": {
473474
"includeAttachments":
474-
filter["attachments"]
475-
if filter and "attachments" in filter else False,
475+
_params.get('include_attachments', False),
476476
"includeMediaAttributes":
477-
filter['media_attributes']
478-
if filter and 'media_attributes' in filter else False,
477+
_params.get('include_media_attributes', False),
479478
"includeMetadata":
480-
filter['metadata_fields']
481-
if filter and 'metadata_fields' in filter else False,
479+
_params.get('include_metadata_fields', False),
480+
"includeDataRowDetails":
481+
_params.get('include_data_row_details', False),
482482
# Arguments locked based on exectuion context
483483
"includeModelRuns":
484484
True,

tests/integration/annotation_import/test_model_run.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,11 +116,13 @@ def test_model_run_export_labels(model_run_with_model_run_data_rows):
116116

117117
def test_model_run_export_labels_v2(model_run_with_model_run_data_rows):
118118
task_name = "test_task"
119-
task = model_run_with_model_run_data_rows.export_labels_v2(
120-
task_name, filter={"media_attributes: true"})
119+
params = {"media_attributes": True}
120+
task = model_run_with_model_run_data_rows.export_labels_v2(task_name,
121+
params=params)
121122
assert task.name == task_name
122123
task.wait_till_done()
123124
assert task.status == "COMPLETE"
125+
# TODO: Download result and check it
124126

125127

126128
@pytest.mark.skipif(condition=os.environ['LABELBOX_TEST_ENVIRON'] == "onprem",

0 commit comments

Comments
 (0)