Update block-ingest docker to 0.2

dotlakeIngest.sh

@@ -44,12 +44,14 @@ fi
 
 # Start Block Ingest Service
 echo "Starting Block Ingest Service..."
-docker run -d --rm -e CHAIN="$CHAIN" -e RELAY_CHAIN="$RELAY_CHAIN" -e WSS="$WSS" -p 8501:8501 eu.gcr.io/parity-data-infra-evaluation/block-ingest:0.1
+docker run -d --rm -e CHAIN="$CHAIN" -e RELAY_CHAIN="$RELAY_CHAIN" -e WSS="$WSS" -p 8501:8501 eu.gcr.io/parity-data-infra-evaluation/block-ingest:0.2
 if [ $? -eq 0 ]; then
     echo "Block Ingest Service started successfully."
 else
     echo "Failed to start Block Ingest Service."
     exit 1
 fi
 
+echo "Starting the services....this will take a minute...."
+sleep 60
 echo "Both services are now running. You can access Substrate API Sidecar at http://localhost:8080 and Block Ingest Service at http://localhost:8501"

ingest/Home.py

@@ -7,7 +7,7 @@
 from streamlit_autorefresh import st_autorefresh
 
 # Function to connect to DuckDB
-def connect_to_db(db_path='/Users/pranaypatil/data_eng_repos/data-applications/blocks.db'):
+def connect_to_db(db_path='blocks.db'):
     return duckdb.connect(db_path, read_only=True)
 
 def parse_arguments():

ingest/pages/Search.py

@@ -66,10 +66,11 @@ def parse_arguments():
 
             # Display events
             st.write("Events:")
-            events = pd.DataFrame([
+            events = [
                 event for extrinsic in result['extrinsics'].iloc[0]
                 for event in extrinsic['events']
-            ])
+            ] + result['onInitialize'].iloc[0]['events'] + result['onFinalize'].iloc[0]['events']
+            events = pd.DataFrame(events)
             st.dataframe(events)
 
         else: