Commit 8bc2645a authored by Aleksandra Mnich's avatar Aleksandra Mnich
Browse files

update the notebooks to pass timestamp to get_fpa_timestamp method

parent f6138075
Pipeline #3177145 passed with stage
in 27 seconds
...@@ -106,11 +106,11 @@ ...@@ -106,11 +106,11 @@
timestamp_pic = rb_query.find_timestamp_pic(timestamp_fgc, spark=spark) timestamp_pic = rb_query.find_timestamp_pic(timestamp_fgc, spark=spark)
# PC Current # PC Current
i_meas_df, i_a_df, i_earth_df, i_earth_pcnt_df, i_ref_df = rb_query.query_pc_pm(timestamp_fgc, timestamp_fgc, signal_names=['I_MEAS', 'I_A', 'I_EARTH', 'I_EARTH_PCNT', 'I_REF']) i_meas_df, i_a_df, i_earth_df, i_earth_pcnt_df, i_ref_df = rb_query.query_pc_pm(timestamp_fgc, timestamp_fgc, signal_names=['I_MEAS', 'I_A', 'I_EARTH', 'I_EARTH_PCNT', 'I_REF'])
timestamp_fgc_ref = rb_query.get_timestamp_ref(col='fgcPm') timestamp_fgc_ref = rb_query.get_fgc_timestamp_ref(timestamp_fgc)
i_meas_ref_df, i_earth_ref_df, i_earth_pcnt_ref_df = rb_query.query_pc_pm(timestamp_fgc_ref, timestamp_fgc_ref, signal_names=['I_MEAS', 'I_EARTH', 'I_EARTH_PCNT']) i_meas_ref_df, i_earth_ref_df, i_earth_pcnt_ref_df = rb_query.query_pc_pm(timestamp_fgc_ref, timestamp_fgc_ref, signal_names=['I_MEAS', 'I_EARTH', 'I_EARTH_PCNT'])
# EE Voltage # EE Voltage
source_timestamp_ee_odd_df = rb_query.find_source_timestamp_ee(timestamp_fgc, system='EE_ODD') source_timestamp_ee_odd_df = rb_query.find_source_timestamp_ee(timestamp_fgc, system='EE_ODD')
timestamp_ee_odd = lhcsmnb.utils.get_at(source_timestamp_ee_odd_df, 0, 'timestamp') timestamp_ee_odd = lhcsmnb.utils.get_at(source_timestamp_ee_odd_df, 0, 'timestamp')
......
...@@ -92,11 +92,11 @@ ...@@ -92,11 +92,11 @@
timestamp_pic = rb_query.find_timestamp_pic(timestamp_fgc, spark=spark) timestamp_pic = rb_query.find_timestamp_pic(timestamp_fgc, spark=spark)
# PC Current # PC Current
i_meas_df, i_a_df, i_earth_df, i_earth_pcnt_df, i_ref_df = rb_query.query_pc_pm(timestamp_fgc, timestamp_fgc, signal_names=['I_MEAS', 'I_A', 'I_EARTH', 'I_EARTH_PCNT', 'I_REF']) i_meas_df, i_a_df, i_earth_df, i_earth_pcnt_df, i_ref_df = rb_query.query_pc_pm(timestamp_fgc, timestamp_fgc, signal_names=['I_MEAS', 'I_A', 'I_EARTH', 'I_EARTH_PCNT', 'I_REF'])
timestamp_fgc_ref = rb_query.get_timestamp_ref(col='fgcPm') timestamp_fgc_ref = rb_query.get_fgc_timestamp_ref(timestamp_fgc)
i_meas_ref_df, i_earth_ref_df, i_earth_pcnt_ref_df = rb_query.query_pc_pm(timestamp_fgc_ref, timestamp_fgc_ref, signal_names=['I_MEAS', 'I_EARTH', 'I_EARTH_PCNT']) i_meas_ref_df, i_earth_ref_df, i_earth_pcnt_ref_df = rb_query.query_pc_pm(timestamp_fgc_ref, timestamp_fgc_ref, signal_names=['I_MEAS', 'I_EARTH', 'I_EARTH_PCNT'])
# QDS # QDS
source_timestamp_qds_df = rb_query.find_source_timestamp_qds_board_ab(timestamp_fgc, duration=[(10, 's'), (10, 's')]) source_timestamp_qds_df = rb_query.find_source_timestamp_qds_board_ab(timestamp_fgc, duration=[(10, 's'), (10, 's')])
......
...@@ -94,12 +94,12 @@ ...@@ -94,12 +94,12 @@
# PC # PC
i_meas_rqd_df, i_a_rqd_df, i_earth_rqd_df, i_earth_pcnt_rqd_df, i_ref_rqd_df = rqd_query.query_pc_pm(timestamp_fgc_rqd, timestamp_fgc_rqd, signal_names=['I_MEAS', 'I_A', 'IEARTH', 'I_EARTH_PCNT', 'I_REF']) i_meas_rqd_df, i_a_rqd_df, i_earth_rqd_df, i_earth_pcnt_rqd_df, i_ref_rqd_df = rqd_query.query_pc_pm(timestamp_fgc_rqd, timestamp_fgc_rqd, signal_names=['I_MEAS', 'I_A', 'IEARTH', 'I_EARTH_PCNT', 'I_REF'])
i_meas_rqf_df, i_a_rqf_df, i_earth_rqf_df, i_earth_pcnt_rqf_df, i_ref_rqf_df = rqf_query.query_pc_pm(timestamp_fgc_rqf, timestamp_fgc_rqf, signal_names=['I_MEAS', 'I_A', 'IEARTH', 'I_EARTH_PCNT', 'I_REF']) i_meas_rqf_df, i_a_rqf_df, i_earth_rqf_df, i_earth_pcnt_rqf_df, i_ref_rqf_df = rqf_query.query_pc_pm(timestamp_fgc_rqf, timestamp_fgc_rqf, signal_names=['I_MEAS', 'I_A', 'IEARTH', 'I_EARTH_PCNT', 'I_REF'])
timestamp_fgc_ref_rqd = rqd_query.get_timestamp_ref(col='fgcPm') timestamp_fgc_ref_rqd = rqd_query.get_fgc_timestamp_ref(timestamp_fgc_rqd)
timestamp_fgc_ref_rqf = rqf_query.get_timestamp_ref(col='fgcPm') timestamp_fgc_ref_rqf = rqf_query.get_fgc_timestamp_ref(timestamp_fgc_rqf)
i_meas_ref_rqd_df, i_earth_rqd_ref_df, i_earth_pcnt_rqd_ref_df = rqd_query.query_pc_pm(timestamp_fgc_ref_rqd, timestamp_fgc_ref_rqd, signal_names=['I_MEAS', 'IEARTH', 'I_EARTH_PCNT']) i_meas_ref_rqd_df, i_earth_rqd_ref_df, i_earth_pcnt_rqd_ref_df = rqd_query.query_pc_pm(timestamp_fgc_ref_rqd, timestamp_fgc_ref_rqd, signal_names=['I_MEAS', 'IEARTH', 'I_EARTH_PCNT'])
i_meas_ref_rqf_df, i_earth_rqf_ref_df, i_earth_pcnt_rqf_ref_df = rqf_query.query_pc_pm(timestamp_fgc_ref_rqf, timestamp_fgc_ref_rqf, signal_names=['I_MEAS', 'IEARTH', 'I_EARTH_PCNT']) i_meas_ref_rqf_df, i_earth_rqf_ref_df, i_earth_pcnt_rqf_ref_df = rqf_query.query_pc_pm(timestamp_fgc_ref_rqf, timestamp_fgc_ref_rqf, signal_names=['I_MEAS', 'IEARTH', 'I_EARTH_PCNT'])
# PIC # PIC
...@@ -126,12 +126,12 @@ ...@@ -126,12 +126,12 @@
t_res_1_rqf_df = rqf_query.query_ee_t_res_pm(lhcsmnb.utils.get_at(source_timestamp_ee_rqf_df, 1, 'timestamp'), timestamp_fgc_rqf, system='EE', signal_names=['T_RES'])[0] t_res_1_rqf_df = rqf_query.query_ee_t_res_pm(lhcsmnb.utils.get_at(source_timestamp_ee_rqf_df, 1, 'timestamp'), timestamp_fgc_rqf, system='EE', signal_names=['T_RES'])[0]
else: else:
t_res_1_rqf_df = pd.DataFrame(columns=['T_RES']) t_res_1_rqf_df = pd.DataFrame(columns=['T_RES'])
# EE - REF # EE - REF
timestamp_ee_ref_rqd = rqd_query.get_timestamp_ref(col='eePm') timestamp_ee_ref_rqd = rqd_query.get_ee_timestamp_ref(timestamp_ee_rqd)
timestamp_ee_ref_rqf = rqf_query.get_timestamp_ref(col='eePm') timestamp_ee_ref_rqf = rqf_query.get_ee_timestamp_ref(timestamp_ee_rqf)
source_timestamp_ee_rqd_ref_df = rqd_query.find_source_timestamp_ee(timestamp_ee_ref_rqd) source_timestamp_ee_rqd_ref_df = rqd_query.find_source_timestamp_ee(timestamp_ee_ref_rqd)
source_timestamp_ee_rqf_ref_df = rqf_query.find_source_timestamp_ee(timestamp_ee_ref_rqf) source_timestamp_ee_rqf_ref_df = rqf_query.find_source_timestamp_ee(timestamp_ee_ref_rqf)
t_res_0_rqd_ref_df = rqd_query.query_ee_t_res_pm(lhcsmnb.utils.get_at(source_timestamp_ee_rqd_ref_df, 0, 'timestamp'), timestamp_fgc_ref_rqd, system='EE', signal_names=['T_RES'])[0] t_res_0_rqd_ref_df = rqd_query.query_ee_t_res_pm(lhcsmnb.utils.get_at(source_timestamp_ee_rqd_ref_df, 0, 'timestamp'), timestamp_fgc_ref_rqd, system='EE', signal_names=['T_RES'])[0]
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment