@@ -600,7 +600,8 @@ async def get_historical_spot_orders(self, market_id: str, **kwargs):
600600 skip = kwargs .get ("skip" ),
601601 limit = kwargs .get ("limit" ),
602602 start_time = kwargs .get ("start_time" ),
603- end_time = kwargs .get ("end_time" )
603+ end_time = kwargs .get ("end_time" ),
604+ state = kwargs .get ("state" )
604605 )
605606 return await self .stubSpotExchange .OrdersHistory (req )
606607
@@ -717,7 +718,8 @@ async def get_historical_derivative_orders(self, market_id: str, **kwargs):
717718 skip = kwargs .get ("skip" ),
718719 limit = kwargs .get ("limit" ),
719720 start_time = kwargs .get ("start_time" ),
720- end_time = kwargs .get ("end_time" )
721+ end_time = kwargs .get ("end_time" ),
722+ state = kwargs .get ("state" )
721723 )
722724 return await self .stubDerivativeExchange .OrdersHistory (req )
723725
@@ -769,9 +771,9 @@ async def stream_derivative_trades(self, **kwargs):
769771 metadata = await self .load_cookie (type = "exchange" )
770772 return self .stubDerivativeExchange .StreamTrades .__call__ (req , metadata = metadata )
771773
772- async def get_derivative_positions (self , market_id : str , ** kwargs ):
774+ async def get_derivative_positions (self , ** kwargs ):
773775 req = derivative_exchange_rpc_pb .PositionsRequest (
774- market_id = market_id ,
776+ market_id = kwargs . get ( " market_id" ) ,
775777 subaccount_id = kwargs .get ("subaccount_id" ),
776778 skip = kwargs .get ("skip" ),
777779 limit = kwargs .get ("limit" )
0 commit comments