Prevent race condition on snap when market cache has not finished pop…

.github/workflows/test.yml

@@ -24,7 +24,6 @@ jobs:
     - name: Install dependencies
       run: |
         pip install -r requirements.txt
-        pip install -r requirements-test.txt
 
     - name: Black fmt
       run: |
@@ -57,7 +56,6 @@ jobs:
         run: |
           pip install -r requirements.txt
           pip install -r requirements-speed.txt
-          pip install -r requirements-test.txt
 
       - name: Unittest
         run: |
@@ -81,7 +79,6 @@ jobs:
     - name: Install dependencies
       run: |
         pip install -r requirements.txt
-        pip install -r requirements-test.txt
 
     - name: Build package and docs
       run: |

HISTORY.rst

@@ -3,6 +3,18 @@
 Release History
 ---------------
 
+2.20.1 (2024-03-12)
++++++++++++++++++++
+
+**Improvements**
+
+- toml improvements
+- repo cleanup
+
+**Bug Fixes**
+
+- Prevent race condition on snap when market cache has not finished populating
+
 2.20.0 (2024-03-11)
 +++++++++++++++++++
 

betfairlightweight/__version__.py

@@ -1,6 +1,6 @@
 __title__ = "betfairlightweight"
 __description__ = "Lightweight python wrapper for Betfair API-NG"
 __url__ = "https://github.com/betcode-org/betfair"
-__version__ = "2.20.0"
+__version__ = "2.20.1"
 __author__ = "Liam Pauling"
 __license__ = "MIT"

betfairlightweight/streaming/betfairstream.py

@@ -1,7 +1,6 @@
 import socket
 import ssl
 import logging
-import datetime
 import collections
 from typing import Optional
 

betfairlightweight/streaming/cache.py

@@ -205,7 +205,7 @@ def __init__(
         cumulative_runner_tv: bool,
     ):
         super(MarketBookCache, self).__init__()
-        self.active = True
+        self.active = False
         self.market_id = market_id
         self.publish_time = publish_time
         self.lightweight = lightweight
@@ -234,7 +234,6 @@ def __init__(
     def update_cache(
         self, market_change: dict, publish_time: int, active: bool
     ) -> None:
-        self.active = active
         self.streaming_update = market_change
         self.publish_time = publish_time
 
@@ -297,6 +296,7 @@ def update_cache(
                     ),
                     2,
                 )
+        self.active = active
 
     def refresh_cache(self) -> None:
         for runner in self.runners:

betfairlightweight/streaming/stream.py

@@ -1,4 +1,3 @@
-import datetime
 import logging
 import time
 from typing import Optional

pyproject.toml

@@ -35,8 +35,8 @@ test = [
     "coverage",
     "mkdocs",
     "mkdocs-material",
+    "build",
     "twine",
-    "wheel",
 ]
 
 [project.urls]
@@ -48,3 +48,11 @@ Changelog = "https://github.com/betcode-org/betfair/blob/master/HISTORY.rst"
 
 [tool.hatch.version]
 path = "betfairlightweight/__version__.py"
+
+[tool.hatch.build.targets.sdist]
+include = [
+    "/betfairlightweight",
+    "/HISTORY.rst",
+    "/README.md",
+    "/tests",
+]

requirements.txt

@@ -1 +1,13 @@
 requests<2.32.0
+
+# Tests & Linting
+black==24.2.0
+coverage
+
+# Documentation
+mkdocs
+mkdocs-material
+
+# Packaging
+build
+twine

tests/test_cache.py

@@ -246,7 +246,7 @@ def setUp(self):
         self.market_book_cache = MarketBookCache("1.2345", 12345, True, False, False)
 
     def test_init(self):
-        self.assertTrue(self.market_book_cache.active)
+        self.assertFalse(self.market_book_cache.active)
         self.assertEqual(self.market_book_cache.market_id, "1.2345")
         self.assertEqual(self.market_book_cache.publish_time, 12345)
         self.assertTrue(self.market_book_cache.lightweight)