Add error handler decorator

Author: Egot Sennov

examples/all_candles.py

@@ -1,8 +1,8 @@
 import os
 from datetime import timedelta
 
-from tinkoff.invest import CandleInterval, Client
-from tinkoff.invest.schemas import CandleSource
+from tinkoff.invest import Client
+from tinkoff.invest.grpc.marketdata import CandleInterval, CandleSource
 from tinkoff.invest.utils import now
 
 TOKEN = os.environ["INVEST_TOKEN"]

examples/async_all_candles.py

@@ -2,8 +2,8 @@
 import os
 from datetime import timedelta
 
-from tinkoff.invest import AsyncClient, CandleInterval
-from tinkoff.invest.schemas import CandleSource
+from tinkoff.invest import AsyncClient
+from tinkoff.invest.grpc.marketdata import CandleInterval, CandleSource
 from tinkoff.invest.utils import now
 
 TOKEN = os.environ["INVEST_TOKEN"]

examples/async_get_asset_reports.py

@@ -3,7 +3,7 @@
 from datetime import timedelta
 
 from tinkoff.invest import AsyncClient
-from tinkoff.invest.schemas import GetAssetReportsRequest
+from tinkoff.invest.grpc.instruments import GetAssetReportsRequest
 from tinkoff.invest.utils import now
 
 TOKEN = os.environ["INVEST_TOKEN"]

examples/async_get_assets.py

@@ -2,7 +2,11 @@
 import os
 
 from tinkoff.invest import AsyncClient
-from tinkoff.invest.schemas import AssetsRequest, InstrumentStatus, InstrumentType
+from tinkoff.invest.grpc.instruments import (
+    AssetsRequest,
+    InstrumentStatus,
+    InstrumentType,
+)
 
 TOKEN = os.environ["INVEST_TOKEN"]
 

examples/async_get_bond_events.py

@@ -1,8 +1,8 @@
 import asyncio
 import os
 
-from tinkoff.invest import AsyncClient, InstrumentType
-from tinkoff.invest.schemas import EventType, GetBondEventsRequest
+from tinkoff.invest import AsyncClient
+from tinkoff.invest.grpc.instruments import GetBondEventsRequest, InstrumentType
 
 TOKEN = os.environ["INVEST_TOKEN"]
 
@@ -18,7 +18,7 @@ async def main():
 
         request = GetBondEventsRequest(
             instrument_id=bond.uid,
-            type=EventType.EVENT_TYPE_CALL,
+            type=GetBondEventsRequest.EventType.EVENT_TYPE_CALL,
         )
         print(await client.instruments.get_bond_events(request=request))
 

examples/async_get_bonds.py

@@ -2,7 +2,7 @@
 import os
 
 from tinkoff.invest import AsyncClient
-from tinkoff.invest.schemas import InstrumentExchangeType
+from tinkoff.invest.grpc.instruments import InstrumentExchangeType
 
 TOKEN = os.environ["INVEST_TOKEN"]
 

examples/async_get_candles_with_limit.py

@@ -1,7 +1,8 @@
 import asyncio
 import os
 
-from tinkoff.invest import AsyncClient, CandleInterval
+from tinkoff.invest import AsyncClient
+from tinkoff.invest.grpc.marketdata import CandleInterval
 from tinkoff.invest.utils import now
 
 TOKEN = os.environ["INVEST_TOKEN"]

examples/async_get_consensus_forecasts.py

@@ -2,7 +2,7 @@
 import os
 
 from tinkoff.invest import AsyncClient
-from tinkoff.invest.schemas import GetConsensusForecastsRequest, Page
+from tinkoff.invest.grpc.instruments import GetConsensusForecastsRequest, Page
 
 TOKEN = os.environ["INVEST_TOKEN"]
 

examples/async_get_forecast_by.py

@@ -2,7 +2,7 @@
 import os
 
 from tinkoff.invest import AsyncClient
-from tinkoff.invest.schemas import GetForecastRequest
+from tinkoff.invest.grpc.instruments import GetForecastRequest
 
 TOKEN = os.environ["INVEST_TOKEN"]
 

examples/async_get_insider_deals.py

@@ -6,7 +6,7 @@
 import os
 
 from tinkoff.invest import AsyncClient
-from tinkoff.invest.schemas import GetInsiderDealsRequest
+from tinkoff.invest.grpc.instruments import GetInsiderDealsRequest
 
 TOKEN = os.environ["INVEST_TOKEN"]