Error in running redpanda_dxfeed_financial_data example in Docker

[jjchan121]

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?

[jjbrosnan]

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.

[jjbrosnan]

Hi @jjchan121, the fixes have been made. If you pull the latest and re-run, it should work. It did for me.

[jjchan121]

Thanks for the prompt fix! It works now.