Skip to content

Commit

Permalink
Merge pull request #21 from KxSystems/pykx-2.3.2
Browse files Browse the repository at this point in the history
PyKX 2.3.2 release update
  • Loading branch information
cmccarthy1 authored Feb 12, 2024
2 parents b4b2bdf + cafcb57 commit 6de3d97
Show file tree
Hide file tree
Showing 15 changed files with 375 additions and 1,026 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
# PyKX
# PyKX

## Introduction

Expand Down
Binary file modified docs/examples/subscriber/archive.zip
Binary file not shown.
4 changes: 2 additions & 2 deletions docs/examples/subscriber/readme.md
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ q process is started.
```bash
// run the subscriber which will automatically connect
$ python subscriber.py
===== Initial Table =====
===== Initital Table =====
a b
---
4 8
Expand All @@ -58,7 +58,7 @@ a b
2 1
1 8
8 5
===== Initial Table =====
===== Initital Table =====

```

Expand Down
4 changes: 2 additions & 2 deletions docs/examples/subscriber/subscriber.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,9 +30,9 @@ async def main_loop(q):
async def main():
global table
async with kx.RawQConnection(port=5001) as q:
print('===== Initial Table =====')
print('===== Initital Table =====')
print(table)
print('===== Initial Table =====')
print('===== Initital Table =====')
# Set the variable py_server on the q process pointing towards this processes IPC connection
# We use neg to ensure the messages are sent async so no reply is expected from this process
await q('py_server: neg .z.w')
Expand Down
4 changes: 2 additions & 2 deletions docs/examples/subscriber/subscriber_async.py
Original file line number Diff line number Diff line change
Expand Up @@ -25,9 +25,9 @@ async def main_loop(q):
async def main():
global table
async with kx.RawQConnection(port=5001, event_loop=asyncio.get_event_loop()) as q:
print('===== Initial Table =====')
print('===== Initital Table =====')
print(table)
print('===== Initial Table =====')
print('===== Initital Table =====')
# Set the variable py_server on the q process pointing towards this processes IPC connection
# We use neg to ensure the messages are sent async so no reply is expected from this process
await q('py_server: neg .z.w')
Expand Down
Binary file modified docs/examples/threaded_execution/archive.zip
Binary file not shown.
4 changes: 2 additions & 2 deletions docs/examples/threaded_execution/asyncio_threading.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,9 +31,9 @@ async def main():
calls = 1000
conns = [await kx.RawQConnection(port=5001, event_loop=asyncio.get_event_loop()) for _ in range(N)] # noqa
main_q_con = kx.SyncQConnection(port=5001)
print('===== Initial Table =====')
print('===== Initital Table =====')
print(kx.q('table'))
print('===== Initial Table =====')
print('===== Initital Table =====')
# Set the variable py_server on the q process pointing towards this processes IPC connection
# We use neg to ensure the messages are sent async so no reply is expected from this process
[await conns[i](f'py_server{i}: neg .z.w') for i in range(N)]
Expand Down
4 changes: 2 additions & 2 deletions docs/examples/threaded_execution/threading.md
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ upserted all of the rows they have recieved to the table the final table will be

```
$ python asyncio_threading.py
===== Initial Table =====
===== Initital Table =====
a b
---
4 8
Expand All @@ -44,7 +44,7 @@ a b
2 1
1 8
8 5
===== Initial Table =====
===== Initital Table =====
a b
-----
4 8
Expand Down
4 changes: 2 additions & 2 deletions docs/examples/threaded_execution/threads.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,9 +33,9 @@ async def main():
calls = 1000
conns = [await kx.RawQConnection(port=5001, event_loop=asyncio.get_event_loop()) for _ in range(N)] # noqa
main_q_con = kx.SyncQConnection(port=5001)
print('===== Initial Table =====')
print('===== Initital Table =====')
print(kx.q('table'))
print('===== Initial Table =====')
print('===== Initital Table =====')
# Set the variable py_server on the q process pointing towards this processes IPC connection
# We use neg to ensure the messages are sent async so no reply is expected from this process
[await conns[i](f'py_server{i}: neg .z.w') for i in range(N)]
Expand Down
10 changes: 10 additions & 0 deletions docs/release-notes/changelog.md
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,16 @@

Currently PyKX is not compatible with Pandas 2.2.0 or above as it introduced breaking changes which cause data to be cast to the incorrect type.

## PyKX 2.3.2

#### Release Date

2024-02-12

### Fixes and Improvements

- Update of PyKX 4.0 linux shared object to version 2024.02.09, this update is to facilitate deployments on more secure linux/linux-arm environments.

## PyKX 2.3.1

#### Release Date
Expand Down
Loading

0 comments on commit 6de3d97

Please sign in to comment.