Skip to content

More explicit thread constructor #41

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ssnyder-intrinio merged 6 commits into from
Jul 10, 2025
Merged

More explicit thread constructor #41

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
450a0da
Add more cboe and conditions to the readme
ssnyder-intrinio Jul 8, 2025
8b22f01
missed a spot
ssnyder-intrinio Jul 10, 2025
fb99d6d
version bump
ssnyder-intrinio Jul 10, 2025
a4b7d89
more explicit thread constructor
ssnyder-intrinio Jul 10, 2025
ea7310b
version bump
ssnyder-intrinio Jul 10, 2025
3219798
Merge branch 'master' into SMS/CboeOneDocs
ssnyder-intrinio Jul 10, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ def on_trade(trade, backlog):

class Summarize(threading.Thread):
def __init__(self, stop_flag):
threading.Thread.__init__(self, args=(), kwargs=None)
threading.Thread.__init__(self, group=None, args=(), kwargs={})
self.daemon = True
self.stop_flag = stop_flag

Expand Down Expand Up @@ -386,7 +386,7 @@ def on_unusual_activity(ua: OptionsUnusualActivity):

class Summarize(threading.Thread):
def __init__(self, stop_flag: threading.Event, intrinio_client: IntrinioRealtimeOptionsClient):
threading.Thread.__init__(self, args=(), kwargs=None, daemon=True)
threading.Thread.__init__(self, group=None, args=(), kwargs={}, daemon=True)
self.__stop_flag: threading.Event = stop_flag
self.__client = intrinio_client

Expand Down
2 changes: 1 addition & 1 deletion example_app_equities.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ def on_trade(trade, backlog):

class Summarize(threading.Thread):
def __init__(self, stop_flag):
threading.Thread.__init__(self, args=(), kwargs=None)
threading.Thread.__init__(self, group=None, args=(), kwargs={})
self.daemon = True
self.stop_flag = stop_flag

Expand Down
2 changes: 1 addition & 1 deletion example_app_options.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ def on_unusual_activity(ua: OptionsUnusualActivity):

class Summarize(threading.Thread):
def __init__(self, stop_flag: threading.Event, intrinio_client: IntrinioRealtimeOptionsClient):
threading.Thread.__init__(self, args=(), kwargs=None, daemon=True)
threading.Thread.__init__(self, group=None, args=(), kwargs={}, daemon=True)
self.__stop_flag: threading.Event = stop_flag
self.__client = intrinio_client

Expand Down
6 changes: 3 additions & 3 deletions intriniorealtime/equities_client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
HEADER_MESSAGE_FORMAT_KEY = "UseNewEquitiesFormat"
HEADER_MESSAGE_FORMAT_VALUE = "v2"
HEADER_CLIENT_INFORMATION_KEY = "Client-Information"
HEADER_CLIENT_INFORMATION_VALUE = "IntrinioPythonSDKv6.0.2"
HEADER_CLIENT_INFORMATION_VALUE = "IntrinioPythonSDKv6.0.3"


class EquitiesQuote:
Expand Down Expand Up @@ -355,7 +355,7 @@ def valid_api_key(self, api_key: str):

class EquitiesQuoteReceiver(threading.Thread):
def __init__(self, client):
threading.Thread.__init__(self, args=(), kwargs=None)
threading.Thread.__init__(self, group=None, args=(), kwargs={})
self.daemon = True
self.client = client
self.enabled = True
Expand Down Expand Up @@ -458,7 +458,7 @@ def on_message(self, ws, message):

class EquitiesQuoteHandler(threading.Thread):
def __init__(self, client, bypass_parsing: bool):
threading.Thread.__init__(self, args=(), kwargs=None)
threading.Thread.__init__(self, group=None, args=(), kwargs={})
self.daemon = True
self.client = client
self.bypass_parsing = bypass_parsing
Expand Down
4 changes: 2 additions & 2 deletions intriniorealtime/equities_replay_client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -228,7 +228,7 @@ def refresh_channels(self):

class FileParsingThread(threading.Thread):
def __init__(self, client):
threading.Thread.__init__(self, args=(), kwargs=None)
threading.Thread.__init__(self, group=None, args=(), kwargs={})
self.daemon = True
self.client = client
self.enabled = True
Expand Down Expand Up @@ -434,7 +434,7 @@ def on_message(self, ws, message):

class QuoteHandlingThread(threading.Thread):
def __init__(self, client):
threading.Thread.__init__(self, args=(), kwargs=None)
threading.Thread.__init__(self, group=None, args=(), kwargs={})
self.daemon = True
self.client = client
self._csv_lock = threading.Lock()
Expand Down
4 changes: 2 additions & 2 deletions setup.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ def readme():
setup(
name = 'intriniorealtime',
packages = ['intriniorealtime'],
version = '6.0.2',
version = '6.0.3',
author = 'Intrinio Python SDK for Real-Time Stock Prices',
author_email = 'success@intrinio.com',
url = 'https://intrinio.com',
Expand All @@ -16,7 +16,7 @@ def readme():
long_description_content_type = 'text/markdown',
install_requires = ['requests>=2.26.0','websocket-client>=1.2.1','wsaccel>=0.6.3', 'intrinio-sdk>=6.26.0'],
python_requires = '~=3.10',
download_url = 'https://github.com/intrinio/intrinio-realtime-python-sdk/archive/v6.0.2.tar.gz',
download_url = 'https://github.com/intrinio/intrinio-realtime-python-sdk/archive/v6.0.3.tar.gz',
keywords = ['realtime','stock prices','intrinio','stock market','stock data','financial'],
classifiers = [
'Intended Audience :: Financial and Insurance Industry',
Expand Down