@@ -92,7 +92,10 @@ def test_bulk_upsert_datarow_metadata(datarow, mdo: DataRowMetadataOntology):
92
92
mdo .bulk_upsert ([metadata ])
93
93
exported = mdo .bulk_export ([datarow .uid ])
94
94
assert len (exported )
95
- assert len ([field for field in exported [0 ].fields if field .schema_id != PRE_COMPUTED_EMBEDDINGS_ID ]) == 4
95
+ assert len ([
96
+ field for field in exported [0 ].fields
97
+ if field .schema_id != PRE_COMPUTED_EMBEDDINGS_ID
98
+ ]) == 4
96
99
97
100
98
101
@pytest .mark .slow
@@ -104,13 +107,15 @@ def test_large_bulk_upsert_datarow_metadata(big_dataset, mdo):
104
107
errors = mdo .bulk_upsert (metadata )
105
108
assert len (errors ) == 0
106
109
107
-
108
110
metadata_lookup = {
109
111
metadata .data_row_id : metadata
110
112
for metadata in mdo .bulk_export (data_row_ids )
111
113
}
112
114
for data_row_id in data_row_ids :
113
- assert len ([f for f in metadata_lookup .get (data_row_id ).fields if f .schema_id != PRE_COMPUTED_EMBEDDINGS_ID ]), metadata_lookup .get (data_row_id ).fields
115
+ assert len ([
116
+ f for f in metadata_lookup .get (data_row_id ).fields
117
+ if f .schema_id != PRE_COMPUTED_EMBEDDINGS_ID
118
+ ]), metadata_lookup .get (data_row_id ).fields
114
119
115
120
116
121
def test_bulk_delete_datarow_metadata (datarow , mdo ):
@@ -170,7 +175,10 @@ def test_large_bulk_delete_datarow_metadata(big_dataset, mdo):
170
175
errors = mdo .bulk_delete (deletes )
171
176
assert len (errors ) == 0
172
177
for data_row_id in data_row_ids :
173
- fields = [f for f in mdo .bulk_export ([data_row_id ])[0 ].fields if f .schema_id != PRE_COMPUTED_EMBEDDINGS_ID ]
178
+ fields = [
179
+ f for f in mdo .bulk_export ([data_row_id ])[0 ].fields
180
+ if f .schema_id != PRE_COMPUTED_EMBEDDINGS_ID
181
+ ]
174
182
assert len (fields ) == 1 , fields
175
183
assert EMBEDDING_SCHEMA_ID not in [field .schema_id for field in fields ]
176
184
@@ -192,7 +200,8 @@ def test_bulk_delete_datarow_enum_metadata(datarow: DataRow, mdo):
192
200
DeleteDataRowMetadata (data_row_id = datarow .uid , fields = [SPLIT_SCHEMA_ID ])
193
201
])
194
202
exported = mdo .bulk_export ([datarow .uid ])[0 ].fields
195
- assert len ([f for f in exported if f .schema_id != PRE_COMPUTED_EMBEDDINGS_ID ]) == 0
203
+ assert len (
204
+ [f for f in exported if f .schema_id != PRE_COMPUTED_EMBEDDINGS_ID ]) == 0
196
205
197
206
198
207
def test_raise_enum_upsert_schema_error (datarow , mdo ):
0 commit comments