-
Notifications
You must be signed in to change notification settings - Fork 95
Hello,
I am trying to run the example in the GitHub example redpanda_dxfeed_financial_data to see how Deephaven is integrated with redpanda.
https://github.com/deephaven-examples/redpanda_dxfeed_financial_data/tree/main
But I have got the following error.
redpanda_dxfeed_financial_data-deephaven-1 | series = ck.consume({'bootstrap.servers': 'redpanda:29092'} , 'Series', key_spec=KeyValueSpec.IGNORE, value_spec=ck.json_spec([
redpanda_dxfeed_financial_data-deephaven-1 | ('Symbol', dht.string),
redpanda_dxfeed_financial_data-deephaven-1 | ('EventFlags', dht.int_),
redpanda_dxfeed_financial_data-deephaven-1 | ('Index', dht.int64),
redpanda_dxfeed_financial_data-deephaven-1 | ('Timestamp', dht.DateTime),
redpanda_dxfeed_financial_data-deephaven-1 | ('Sequence', dht.int_),
redpanda_dxfeed_financial_data-deephaven-1 | ('Expiration', dht.int_),
redpanda_dxfeed_financial_data-deephaven-1 | ('Volatility', dht.double),
redpanda_dxfeed_financial_data-deephaven-1 | ('PutCallRatio', dht.double),
redpanda_dxfeed_financial_data-deephaven-1 | ('ForwardPrice', dht.double),
redpanda_dxfeed_financial_data-deephaven-1 | ('Dividend', dht.double),
redpanda_dxfeed_financial_data-deephaven-1 | ('Interest', dht.double)
redpanda_dxfeed_financial_data-deephaven-1 | ]),table_type = TableType.Append).sort_descending(["KafkaOffset"])
redpanda_dxfeed_financial_data-deephaven-1 |
redpanda_dxfeed_financial_data-deephaven-1 | from deephaven import new_table
redpanda_dxfeed_financial_data-deephaven-1 | from deephaven.column import string_col
redpanda_dxfeed_financial_data-deephaven-1 |
redpanda_dxfeed_financial_data-deephaven-1 | symbols = new_table([
redpanda_dxfeed_financial_data-deephaven-1 | string_col("Symbol", ['SPY', 'AAPL', 'IBM', 'MSFT', 'DIA', 'XLF', 'GOOG', 'AMZN', 'TSLA', 'SPX', 'HPQ', 'CSCO', 'INTC', 'AXP'])
redpanda_dxfeed_financial_data-deephaven-1 | ])
redpanda_dxfeed_financial_data-deephaven-1 | Initiating shutdown due to: Uncaught exception in thread main
redpanda_dxfeed_financial_data-deephaven-1 | java.lang.RuntimeException: Error in Python interpreter:
redpanda_dxfeed_financial_data-deephaven-1 | Type: <class 'AttributeError'>
redpanda_dxfeed_financial_data-deephaven-1 | Value: module 'deephaven.dtypes' has no attribute 'DateTime'
redpanda_dxfeed_financial_data-deephaven-1 | Line: 16
redpanda_dxfeed_financial_data-deephaven-1 | Namespace: <module>
redpanda_dxfeed_financial_data-deephaven-1 | File: <string>
redpanda_dxfeed_financial_data-deephaven-1 | Traceback (most recent call last):
redpanda_dxfeed_financial_data-deephaven-1 | File "<string>", line 16, in <module>
Any idea?
All reactions
Hi @jjchan121, this error is caused by an outdated time library in that repository. That code hasn't been updated in some time, so the error ('deephaven.dtypes' has no attribute 'DateTime') is accurate. This code would probably work in deephaven-core v0.24.x and earlier.
I don't recommend reverting back to an older version - I'll merge a fix for this today, and I'll reply again to this thread when it's in.
Replies: 2 comments 1 reply
Hi @jjchan121, this error is caused by an outdated time library in that repository. That code hasn't been updated in some time, so the error ('deephaven.dtypes' has no attribute 'DateTime') is accurate. This code would probably work in deephaven-core v0.24.x and earlier.
I don't recommend reverting back to an older version - I'll merge a fix for this today, and I'll reply again to this thread when it's in.
All reactions
Hi @jjchan121, the fixes have been made. If you pull the latest and re-run, it should work. It did for me.
All reactions
Thanks for the prompt fix! It works now.