Skip to content

Commit 8d45f01

Browse files
More explicit thread constructor (#41)
* Add more cboe and conditions to the readme * missed a spot * version bump * more explicit thread constructor * version bump
1 parent 5e4c7db commit 8d45f01

6 files changed

Lines changed: 11 additions & 11 deletions

File tree

README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ def on_trade(trade, backlog):
8181

8282
class Summarize(threading.Thread):
8383
def __init__(self, stop_flag):
84-
threading.Thread.__init__(self, args=(), kwargs=None)
84+
threading.Thread.__init__(self, group=None, args=(), kwargs={})
8585
self.daemon = True
8686
self.stop_flag = stop_flag
8787

@@ -386,7 +386,7 @@ def on_unusual_activity(ua: OptionsUnusualActivity):
386386

387387
class Summarize(threading.Thread):
388388
def __init__(self, stop_flag: threading.Event, intrinio_client: IntrinioRealtimeOptionsClient):
389-
threading.Thread.__init__(self, args=(), kwargs=None, daemon=True)
389+
threading.Thread.__init__(self, group=None, args=(), kwargs={}, daemon=True)
390390
self.__stop_flag: threading.Event = stop_flag
391391
self.__client = intrinio_client
392392

example_app_equities.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ def on_trade(trade, backlog):
3232

3333
class Summarize(threading.Thread):
3434
def __init__(self, stop_flag):
35-
threading.Thread.__init__(self, args=(), kwargs=None)
35+
threading.Thread.__init__(self, group=None, args=(), kwargs={})
3636
self.daemon = True
3737
self.stop_flag = stop_flag
3838

example_app_options.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ def on_unusual_activity(ua: OptionsUnusualActivity):
8181

8282
class Summarize(threading.Thread):
8383
def __init__(self, stop_flag: threading.Event, intrinio_client: IntrinioRealtimeOptionsClient):
84-
threading.Thread.__init__(self, args=(), kwargs=None, daemon=True)
84+
threading.Thread.__init__(self, group=None, args=(), kwargs={}, daemon=True)
8585
self.__stop_flag: threading.Event = stop_flag
8686
self.__client = intrinio_client
8787

intriniorealtime/equities_client.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
HEADER_MESSAGE_FORMAT_KEY = "UseNewEquitiesFormat"
3333
HEADER_MESSAGE_FORMAT_VALUE = "v2"
3434
HEADER_CLIENT_INFORMATION_KEY = "Client-Information"
35-
HEADER_CLIENT_INFORMATION_VALUE = "IntrinioPythonSDKv6.0.2"
35+
HEADER_CLIENT_INFORMATION_VALUE = "IntrinioPythonSDKv6.0.3"
3636

3737

3838
class EquitiesQuote:
@@ -355,7 +355,7 @@ def valid_api_key(self, api_key: str):
355355

356356
class EquitiesQuoteReceiver(threading.Thread):
357357
def __init__(self, client):
358-
threading.Thread.__init__(self, args=(), kwargs=None)
358+
threading.Thread.__init__(self, group=None, args=(), kwargs={})
359359
self.daemon = True
360360
self.client = client
361361
self.enabled = True
@@ -458,7 +458,7 @@ def on_message(self, ws, message):
458458

459459
class EquitiesQuoteHandler(threading.Thread):
460460
def __init__(self, client, bypass_parsing: bool):
461-
threading.Thread.__init__(self, args=(), kwargs=None)
461+
threading.Thread.__init__(self, group=None, args=(), kwargs={})
462462
self.daemon = True
463463
self.client = client
464464
self.bypass_parsing = bypass_parsing

intriniorealtime/equities_replay_client.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -228,7 +228,7 @@ def refresh_channels(self):
228228

229229
class FileParsingThread(threading.Thread):
230230
def __init__(self, client):
231-
threading.Thread.__init__(self, args=(), kwargs=None)
231+
threading.Thread.__init__(self, group=None, args=(), kwargs={})
232232
self.daemon = True
233233
self.client = client
234234
self.enabled = True
@@ -434,7 +434,7 @@ def on_message(self, ws, message):
434434

435435
class QuoteHandlingThread(threading.Thread):
436436
def __init__(self, client):
437-
threading.Thread.__init__(self, args=(), kwargs=None)
437+
threading.Thread.__init__(self, group=None, args=(), kwargs={})
438438
self.daemon = True
439439
self.client = client
440440
self._csv_lock = threading.Lock()

setup.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ def readme():
77
setup(
88
name = 'intriniorealtime',
99
packages = ['intriniorealtime'],
10-
version = '6.0.2',
10+
version = '6.0.3',
1111
author = 'Intrinio Python SDK for Real-Time Stock Prices',
1212
author_email = 'success@intrinio.com',
1313
url = 'https://intrinio.com',
@@ -16,7 +16,7 @@ def readme():
1616
long_description_content_type = 'text/markdown',
1717
install_requires = ['requests>=2.26.0','websocket-client>=1.2.1','wsaccel>=0.6.3', 'intrinio-sdk>=6.26.0'],
1818
python_requires = '~=3.10',
19-
download_url = 'https://github.com/intrinio/intrinio-realtime-python-sdk/archive/v6.0.2.tar.gz',
19+
download_url = 'https://github.com/intrinio/intrinio-realtime-python-sdk/archive/v6.0.3.tar.gz',
2020
keywords = ['realtime','stock prices','intrinio','stock market','stock data','financial'],
2121
classifiers = [
2222
'Intended Audience :: Financial and Insurance Industry',

0 commit comments

Comments
 (0)