@@ -2429,7 +2429,9 @@ async def query_data_agreement_instances(self, tag_query: dict = None) -> typing
2429
2429
# Append the data agreement instance to data_agreement_instances
2430
2430
data_agreement_instances .append ({
2431
2431
"data_exchange_record_id" : da_instance_metadata_record .tags .get ("data_exchange_record_id" ),
2432
- "data_agreement" : data_agreement_instance .serialize ()
2432
+ "data_agreement" : data_agreement_instance .serialize (),
2433
+ "created_at" : str_to_epoch (cred_ex_record .created_at ),
2434
+ "updated_at" : str_to_epoch (cred_ex_record .updated_at )
2433
2435
})
2434
2436
2435
2437
except StorageError :
@@ -2453,12 +2455,18 @@ async def query_data_agreement_instances(self, tag_query: dict = None) -> typing
2453
2455
# Append the data agreement instance to data_agreement_instances
2454
2456
data_agreement_instances .append ({
2455
2457
"data_exchange_record_id" : da_instance_metadata_record .tags .get ("data_exchange_record_id" ),
2456
- "data_agreement" : data_agreement_instance .serialize ()
2458
+ "data_agreement" : data_agreement_instance .serialize (),
2459
+ "created_at" : str_to_epoch (pres_ex_record .created_at ),
2460
+ "updated_at" : str_to_epoch (pres_ex_record .updated_at )
2457
2461
})
2458
2462
2459
2463
except StorageError :
2460
2464
pass
2461
2465
2466
+ # Sort data_agreement_instances by created_at in descending order
2467
+ data_agreement_instances = sorted (
2468
+ data_agreement_instances , key = lambda k : k ['created_at' ], reverse = True )
2469
+
2462
2470
return data_agreement_instances
2463
2471
2464
2472
async def construct_data_agreement_verify_request (self , * , data_agreement_id : str ) -> DataAgreementVerify :
@@ -4497,7 +4505,7 @@ def serialize_connection_record(cls, connection_records: typing.List[ConnectionR
4497
4505
Args:
4498
4506
connection_records: List of connection records.
4499
4507
is_list: If true, serialize as list.
4500
-
4508
+
4501
4509
Returns:
4502
4510
List of serialized connection records.
4503
4511
"""
@@ -4520,6 +4528,7 @@ def serialize_connection_record(cls, connection_records: typing.List[ConnectionR
4520
4528
})
4521
4529
4522
4530
# Sort by created_at in descending order
4523
- connection_records_list = sorted (connection_records_list , key = lambda k : k ['created_at' ], reverse = True )
4531
+ connection_records_list = sorted (
4532
+ connection_records_list , key = lambda k : k ['created_at' ], reverse = True )
4524
4533
4525
4534
return connection_records_list if is_list else connection_records_list [0 ]
0 commit comments