@@ -229,7 +229,8 @@ <h1>Source code for omc3.harpy.handler</h1><div class="highlight"><pre>
229229< span class ="sd "> """</ span >
230230< span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> __future__</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> annotations</ span >
231231
232- < span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> os.path</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> basename</ span > < span class ="p "> ,</ span > < span class ="n "> join</ span >
232+ < span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> pathlib</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> Path</ span >
233+ < span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> typing</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> TYPE_CHECKING</ span >
233234
234235< span class ="kn "> import</ span > < span class ="w "> </ span > < span class ="nn "> numpy</ span > < span class ="w "> </ span > < span class ="k "> as</ span > < span class ="w "> </ span > < span class ="nn "> np</ span >
235236< span class ="kn "> import</ span > < span class ="w "> </ span > < span class ="nn "> pandas</ span > < span class ="w "> </ span > < span class ="k "> as</ span > < span class ="w "> </ span > < span class ="nn "> pd</ span >
@@ -255,14 +256,19 @@ <h1>Source code for omc3.harpy.handler</h1><div class="highlight"><pre>
255256< span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> omc3.utils</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> logging_tools</ span >
256257< span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> omc3.utils.contexts</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> timeit</ span >
257258
259+ < span class ="k "> if</ span > < span class ="n "> TYPE_CHECKING</ span > < span class ="p "> :</ span >
260+ < span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> typing</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> Any</ span >
261+
262+ < span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> turn_by_turn</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> TbtData</ span >
263+
258264< span class ="n "> LOGGER</ span > < span class ="o "> =</ span > < span class ="n "> logging_tools</ span > < span class ="o "> .</ span > < span class ="n "> get_logger</ span > < span class ="p "> (</ span > < span class ="vm "> __name__</ span > < span class ="p "> )</ span >
259265< span class ="n "> ALL_PLANES</ span > < span class ="o "> =</ span > < span class ="p "> (</ span > < span class ="o "> *</ span > < span class ="n "> PLANES</ span > < span class ="p "> ,</ span > < span class ="s2 "> "Z"</ span > < span class ="p "> )</ span >
260266< span class ="n "> PLANE_TO_NUM</ span > < span class ="o "> =</ span > < span class ="p "> {</ span > < span class ="o "> **</ span > < span class ="n "> P2N</ span > < span class ="p "> ,</ span > < span class ="s2 "> "Z"</ span > < span class ="p "> :</ span > < span class ="mi "> 3</ span > < span class ="p "> }</ span >
261267
262268
263269< div class ="viewcode-block " id ="run_per_bunch ">
264270< a class ="viewcode-back " href ="../../../modules/harpy.html#omc3.harpy.handler.run_per_bunch "> [docs]</ a >
265- < span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> run_per_bunch</ span > < span class ="p "> (</ span > < span class ="n "> tbt_data</ span > < span class ="p "> ,</ span > < span class ="n "> harpy_input</ span > < span class ="p "> ):</ span >
271+ < span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> run_per_bunch</ span > < span class ="p "> (</ span > < span class ="n "> tbt_data</ span > < span class ="p "> : </ span > < span class =" n " > TbtData </ span > < span class =" p " > ,</ span > < span class ="n "> harpy_input</ span > < span class ="p "> : </ span > < span class =" nb " > dict </ span > < span class =" p " > [ </ span > < span class =" nb " > str </ span > < span class =" p " > , </ span > < span class =" n " > Any </ span > < span class =" p " > ] ):</ span >
266272< span class ="w "> </ span > < span class ="sd "> """</ span >
267273< span class ="sd "> Cleans data, analyses frequencies and searches for resonances.</ span >
268274
@@ -275,7 +281,7 @@ <h1>Source code for omc3.harpy.handler</h1><div class="highlight"><pre>
275281< span class ="sd "> """</ span >
276282 < span class ="n "> model</ span > < span class ="o "> =</ span > < span class ="kc "> None</ span > < span class ="k "> if</ span > < span class ="n "> harpy_input</ span > < span class ="o "> .</ span > < span class ="n "> model</ span > < span class ="ow "> is</ span > < span class ="kc "> None</ span > < span class ="k "> else</ span > < span class ="n "> tfs</ span > < span class ="o "> .</ span > < span class ="n "> read</ span > < span class ="p "> (</ span > < span class ="n "> harpy_input</ span > < span class ="o "> .</ span > < span class ="n "> model</ span > < span class ="p "> ,</ span > < span class ="n "> index</ span > < span class ="o "> =</ span > < span class ="n "> COL_NAME</ span > < span class ="p "> )</ span > < span class ="o "> .</ span > < span class ="n "> loc</ span > < span class ="p "> [:,</ span > < span class ="s1 "> 'S'</ span > < span class ="p "> ]</ span >
277283 < span class ="n "> bpm_datas</ span > < span class ="p "> ,</ span > < span class ="n "> usvs</ span > < span class ="p "> ,</ span > < span class ="n "> lins</ span > < span class ="p "> ,</ span > < span class ="n "> bad_bpms</ span > < span class ="o "> =</ span > < span class ="p "> {},</ span > < span class ="p "> {},</ span > < span class ="p "> {},</ span > < span class ="p "> {}</ span >
278- < span class ="n "> output_file_path</ span > < span class ="o "> =</ span > < span class ="n "> _get_output_path_without_suffix</ span > < span class ="p "> (</ span > < span class ="n "> harpy_input</ span > < span class ="o "> .</ span > < span class ="n "> outputdir</ span > < span class ="p "> ,</ span > < span class ="n "> harpy_input</ span > < span class ="o "> .</ span > < span class ="n "> files</ span > < span class ="p "> )</ span >
284+ < span class ="n "> output_file_path</ span > < span class =" p " > : </ span > < span class =" n " > Path </ span > < span class ="o "> =</ span > < span class ="n "> _get_output_path_without_suffix</ span > < span class ="p "> (</ span > < span class ="n "> harpy_input</ span > < span class ="o "> .</ span > < span class ="n "> outputdir</ span > < span class ="p "> ,</ span > < span class ="n "> harpy_input</ span > < span class ="o "> .</ span > < span class ="n "> files</ span > < span class ="p "> )</ span >
279285 < span class ="k "> for</ span > < span class ="n "> plane</ span > < span class ="ow "> in</ span > < span class ="n "> PLANES</ span > < span class ="p "> :</ span >
280286 < span class ="n "> bpm_data</ span > < span class ="o "> =</ span > < span class ="n "> _get_cut_tbt_matrix</ span > < span class ="p "> (</ span > < span class ="n "> tbt_data</ span > < span class ="p "> ,</ span > < span class ="n "> harpy_input</ span > < span class ="o "> .</ span > < span class ="n "> turns</ span > < span class ="p "> ,</ span > < span class ="n "> plane</ span > < span class ="p "> )</ span >
281287 < span class ="n "> bpm_data</ span > < span class ="o "> =</ span > < span class ="n "> _scale_to_meters</ span > < span class ="p "> (</ span > < span class ="n "> bpm_data</ span > < span class ="p "> ,</ span > < span class ="n "> harpy_input</ span > < span class ="o "> .</ span > < span class ="n "> unit</ span > < span class ="p "> )</ span >
@@ -404,23 +410,22 @@ <h1>Source code for omc3.harpy.handler</h1><div class="highlight"><pre>
404410 < span class ="k "> return</ span > < span class ="n "> headers</ span >
405411
406412
407- < span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> _write_bad_bpms</ span > < span class ="p "> (</ span > < span class ="n "> output_path_without_suffix</ span > < span class ="p "> ,</ span > < span class ="n "> plane</ span > < span class ="p "> ,</ span > < span class ="n "> bad_bpms_with_reasons</ span > < span class ="p "> ):</ span >
408- < span class ="k "> with</ span > < span class ="nb "> open</ span > < span class ="p "> (</ span > < span class ="sa "> f</ span > < span class ="s2 "> "</ span > < span class ="si "> {</ span > < span class ="n "> output_path_without_suffix</ span > < span class ="si "> }</ span > < span class ="s2 "> .bad_bpms_</ span > < span class ="si "> {</ span > < span class ="n "> plane</ span > < span class ="o "> .</ span > < span class ="n "> lower</ span > < span class ="p "> ()</ span > < span class ="si "> }</ span > < span class ="s2 "> "</ span > < span class ="p "> ,</ span > < span class ="s1 "> 'w'</ span > < span class ="p "> )</ span > < span class ="k "> as</ span > < span class ="n "> bad_bpms_file</ span > < span class ="p "> :</ span >
409- < span class ="k "> for</ span > < span class ="n "> line</ span > < span class ="ow "> in</ span > < span class ="n "> bad_bpms_with_reasons</ span > < span class ="p "> :</ span >
410- < span class ="n "> bad_bpms_file</ span > < span class ="o "> .</ span > < span class ="n "> write</ span > < span class ="p "> (</ span > < span class ="sa "> f</ span > < span class ="s2 "> "</ span > < span class ="si "> {</ span > < span class ="n "> line</ span > < span class ="si "> }</ span > < span class ="se "> \n</ span > < span class ="s2 "> "</ span > < span class ="p "> )</ span >
413+ < span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> _write_bad_bpms</ span > < span class ="p "> (</ span > < span class ="n "> output_path_without_suffix</ span > < span class ="p "> :</ span > < span class ="n "> Path</ span > < span class ="o "> |</ span > < span class ="nb "> str</ span > < span class ="p "> ,</ span > < span class ="n "> plane</ span > < span class ="p "> :</ span > < span class ="nb "> str</ span > < span class ="p "> ,</ span > < span class ="n "> bad_bpms_with_reasons</ span > < span class ="p "> :</ span > < span class ="nb "> str</ span > < span class ="p "> )</ span > < span class ="o "> -></ span > < span class ="kc "> None</ span > < span class ="p "> :</ span >
414+ < span class ="n "> bad_bpms_file</ span > < span class ="o "> =</ span > < span class ="n "> Path</ span > < span class ="p "> (</ span > < span class ="sa "> f</ span > < span class ="s2 "> "</ span > < span class ="si "> {</ span > < span class ="n "> output_path_without_suffix</ span > < span class ="si "> }</ span > < span class ="s2 "> .bad_bpms_</ span > < span class ="si "> {</ span > < span class ="n "> plane</ span > < span class ="o "> .</ span > < span class ="n "> lower</ span > < span class ="p "> ()</ span > < span class ="si "> }</ span > < span class ="s2 "> "</ span > < span class ="p "> )</ span >
415+ < span class ="n "> bad_bpms_file</ span > < span class ="o "> .</ span > < span class ="n "> write_text</ span > < span class ="p "> (</ span > < span class ="s2 "> "</ span > < span class ="se "> \n</ span > < span class ="s2 "> "</ span > < span class ="o "> .</ span > < span class ="n "> join</ span > < span class ="p "> (</ span > < span class ="n "> bad_bpms_with_reasons</ span > < span class ="p "> )</ span > < span class ="o "> +</ span > < span class ="s2 "> "</ span > < span class ="se "> \n</ span > < span class ="s2 "> "</ span > < span class ="p "> )</ span >
411416
412417
413- < span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> _write_spectrum</ span > < span class ="p "> (</ span > < span class ="n "> output_path_without_suffix</ span > < span class ="p "> ,</ span > < span class ="n "> plane</ span > < span class ="p "> ,</ span > < span class ="n "> spectra</ span > < span class ="p "> ) :</ span >
418+ < span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> _write_spectrum</ span > < span class ="p "> (</ span > < span class ="n "> output_path_without_suffix</ span > < span class ="p "> : </ span > < span class =" n " > Path </ span > < span class =" o " > | </ span > < span class =" nb " > str </ span > < span class =" p " > ,</ span > < span class ="n "> plane</ span > < span class ="p "> : </ span > < span class =" nb " > str </ span > < span class =" p " > ,</ span > < span class ="n "> spectra</ span > < span class ="p "> : </ span > < span class =" n " > tfs </ span > < span class =" o " > . </ span > < span class =" n " > TfsDataFrame </ span > < span class =" p " > ) </ span > < span class =" o " > -> </ span > < span class =" kc " > None </ span > < span class =" p " > :</ span >
414419 < span class ="n "> tfs</ span > < span class ="o "> .</ span > < span class ="n "> write</ span > < span class ="p "> (</ span > < span class ="sa "> f</ span > < span class ="s2 "> "</ span > < span class ="si "> {</ span > < span class ="n "> output_path_without_suffix</ span > < span class ="si "> }{</ span > < span class ="n "> FILE_AMPS_EXT</ span > < span class ="o "> .</ span > < span class ="n "> format</ span > < span class ="p "> (</ span > < span class ="n "> plane</ span > < span class ="o "> =</ span > < span class ="n "> plane</ span > < span class ="o "> .</ span > < span class ="n "> lower</ span > < span class ="p "> ())</ span > < span class ="si "> }</ span > < span class ="s2 "> "</ span > < span class ="p "> ,</ span > < span class ="n "> spectra</ span > < span class ="p "> [</ span > < span class ="s2 "> "COEFFS"</ span > < span class ="p "> ]</ span > < span class ="o "> .</ span > < span class ="n "> abs</ span > < span class ="p "> ()</ span > < span class ="o "> .</ span > < span class ="n "> T</ span > < span class ="p "> )</ span >
415420 < span class ="n "> tfs</ span > < span class ="o "> .</ span > < span class ="n "> write</ span > < span class ="p "> (</ span > < span class ="sa "> f</ span > < span class ="s2 "> "</ span > < span class ="si "> {</ span > < span class ="n "> output_path_without_suffix</ span > < span class ="si "> }{</ span > < span class ="n "> FILE_FREQS_EXT</ span > < span class ="o "> .</ span > < span class ="n "> format</ span > < span class ="p "> (</ span > < span class ="n "> plane</ span > < span class ="o "> =</ span > < span class ="n "> plane</ span > < span class ="o "> .</ span > < span class ="n "> lower</ span > < span class ="p "> ())</ span > < span class ="si "> }</ span > < span class ="s2 "> "</ span > < span class ="p "> ,</ span > < span class ="n "> spectra</ span > < span class ="p "> [</ span > < span class ="s2 "> "FREQS"</ span > < span class ="p "> ]</ span > < span class ="o "> .</ span > < span class ="n "> T</ span > < span class ="p "> )</ span >
416421
417422
418- < span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> _write_lin_tfs</ span > < span class ="p "> (</ span > < span class ="n "> output_path_without_suffix</ span > < span class ="p "> ,</ span > < span class ="n "> plane</ span > < span class ="p "> ,</ span > < span class ="n "> lin_frame</ span > < span class ="p "> ) :</ span >
423+ < span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> _write_lin_tfs</ span > < span class ="p "> (</ span > < span class ="n "> output_path_without_suffix</ span > < span class ="p "> : </ span > < span class =" n " > Path </ span > < span class =" o " > | </ span > < span class =" nb " > str </ span > < span class =" p " > ,</ span > < span class ="n "> plane</ span > < span class ="p "> : </ span > < span class =" nb " > str </ span > < span class =" p " > ,</ span > < span class ="n "> lin_frame</ span > < span class ="p "> : </ span > < span class =" n " > tfs </ span > < span class =" o " > . </ span > < span class =" n " > TfsDataFrame </ span > < span class =" p " > ) </ span > < span class =" o " > -> </ span > < span class =" kc " > None </ span > < span class =" p " > :</ span >
419424 < span class ="n "> tfs</ span > < span class ="o "> .</ span > < span class ="n "> write</ span > < span class ="p "> (</ span > < span class ="sa "> f</ span > < span class ="s2 "> "</ span > < span class ="si "> {</ span > < span class ="n "> output_path_without_suffix</ span > < span class ="si "> }{</ span > < span class ="n "> FILE_LIN_EXT</ span > < span class ="o "> .</ span > < span class ="n "> format</ span > < span class ="p "> (</ span > < span class ="n "> plane</ span > < span class ="o "> =</ span > < span class ="n "> plane</ span > < span class ="o "> .</ span > < span class ="n "> lower</ span > < span class ="p "> ())</ span > < span class ="si "> }</ span > < span class ="s2 "> "</ span > < span class ="p "> ,</ span > < span class ="n "> lin_frame</ span > < span class ="p "> )</ span >
420425
421426
422- < span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> _get_output_path_without_suffix</ span > < span class ="p "> (</ span > < span class ="n "> output_dir</ span > < span class ="p "> ,</ span > < span class ="n "> file_path</ span > < span class ="p "> ) :</ span >
423- < span class ="k "> return</ span > < span class ="n "> join </ span > < span class ="p "> (</ span > < span class ="n "> output_dir</ span > < span class ="p "> , </ span > < span class ="n "> basename </ span > < span class ="p "> (</ span > < span class ="n "> file_path</ span > < span class ="p "> )) </ span >
427+ < span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> _get_output_path_without_suffix</ span > < span class ="p "> (</ span > < span class ="n "> output_dir</ span > < span class ="p "> : </ span > < span class =" nb " > str </ span > < span class =" p " > ,</ span > < span class ="n "> file_path</ span > < span class ="p "> : </ span > < span class =" nb " > str </ span > < span class =" p " > ) </ span > < span class =" o " > -> </ span > < span class =" n " > Path </ span > < span class =" p " > :</ span >
428+ < span class ="k "> return</ span > < span class ="n "> Path </ span > < span class ="p "> (</ span > < span class ="n "> output_dir</ span > < span class ="p "> ) </ span > < span class ="o " > / </ span > < span class =" n "> Path </ span > < span class ="p "> (</ span > < span class ="n "> file_path</ span > < span class ="p "> )</ span > < span class =" o " > . </ span > < span class =" n " > name </ span >
424429
425430
426431< span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> _rescale_amps_to_main_line_and_compute_noise</ span > < span class ="p "> (</ span > < span class ="n "> df</ span > < span class ="p "> :</ span > < span class ="n "> pd</ span > < span class ="o "> .</ span > < span class ="n "> DataFrame</ span > < span class ="p "> ,</ span > < span class ="n "> plane</ span > < span class ="p "> :</ span > < span class ="nb "> str</ span > < span class ="p "> )</ span > < span class ="o "> -></ span > < span class ="n "> pd</ span > < span class ="o "> .</ span > < span class ="n "> DataFrame</ span > < span class ="p "> :</ span >
0 commit comments