Commit b3ae5767 authored by thbuffet's avatar thbuffet
Browse files

fix notebook for the references

parent a4990ea7
Pipeline #2570664 passed with stage
in 14 seconds
......@@ -86,7 +86,7 @@
"def query_qh_parallel(input_param):\n",
" source, timestamp, is_ref = input_param\n",
" if is_ref:\n",
" timestamp = Reference.get_quench_heater_reference_discharge('RB', source)\n",
" timestamp = Reference.get_quench_heater_reference_discharge('RB', source, timestamp)\n",
"\n",
" u_hds_dfs = QueryBuilder().with_pm() \\\n",
" .with_timestamp(timestamp) \\\n",
......@@ -181,7 +181,7 @@
" i_hds_dfs = list(filter(lambda col: 'I_HDS' in col.columns.values[0], qh_source_timestamp_dfs_dct[(source, timestamp)]))\n",
" \n",
" # Get matching reference voltage and current\n",
" timestamp_ref = Reference.get_quench_heater_reference_discharge('RB', source)\n",
" timestamp_ref = Reference.get_quench_heater_reference_discharge('RB', source, timestamp)\n",
" u_hds_ref_dfs = list(filter(lambda col: 'U_HDS' in col.columns.values[0], qh_source_timestamp_ref_dfs_dct[(source, timestamp_ref)]))\n",
" i_hds_ref_dfs = list(filter(lambda col: 'I_HDS' in col.columns.values[0], qh_source_timestamp_ref_dfs_dct[(source, timestamp_ref)]))\n",
" \n",
......
......@@ -85,7 +85,7 @@
"def query_qh_parallel(input_param):\n",
" source, timestamp, is_ref = input_param\n",
" if is_ref:\n",
" timestamp = Reference.get_quench_heater_reference_discharge('RQ', source)\n",
" timestamp = Reference.get_quench_heater_reference_discharge('RQ', source, timestamp)\n",
"\n",
" u_hds_dfs = QueryBuilder().with_pm() \\\n",
" .with_timestamp(timestamp) \\\n",
......
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