sf-daq/sf_daq_broker
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_broker.git synced 2026-09-01 11:30:42 +02:00
Code Issues Packages Projects Releases Wiki Activity
87 Commits 4 Branches 0 Tags
eebdf164bafdb5b50bfbc2e4316f1fdabe9c5f55
Commit Graph
87 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
babic_a eebdf164ba Add log output to start writer 2020-08-20 18:39:18 +02:00
babic_a 0dfd0ac65d Make all 3 loggers the same 2020-08-20 18:28:32 +02:00
babic_a c502228544 Fix Pandas issue 2020-08-20 18:20:49 +02:00
babic_a 10f3780b4c Fix small bug 2020-08-20 18:14:35 +02:00
babic_a 20f9672d2d Adjust the default queue 2020-08-20 18:07:16 +02:00
babic_a aa488966e4 Add tag writer selection 2020-08-20 18:03:51 +02:00
babic_a 843206f398 Add static tags to dispatch messages 2020-08-20 18:03:14 +02:00
babic_a 05c9fdc289 Removed routing tag from broker 2020-08-20 18:01:05 +02:00
babic_a 8ff98b3902 Modify the interbroker protocol 2020-08-20 17:51:46 +02:00
babic_a a0e4e8707b Added run log file to call 2020-08-20 17:51:25 +02:00
babic_a 886c7866a0 Moved conversion to bsread writer 2020-08-20 17:51:03 +02:00
babic_a 6d24551114 Added broker writer format 2020-08-20 17:27:58 +02:00
babic_a bd06d554d5 Remove setting of delay 2020-08-20 17:24:25 +02:00
babic_a a5f5d3b363 Fix typo 2020-08-20 17:21:57 +02:00
babic_a 589bf7553c Merge remote-tracking branch 'origin/master' 2020-08-20 17:19:11 +02:00
babic_a 43516e16f4 Writer name in logs 2020-08-20 17:19:04 +02:00
Dmitry Ozerov bd733bdce3 Merge branch 'master' of https://github.com/paulscherrerinstitute/sf_daq_broker 2020-08-20 17:13:31 +02:00
Dmitry Ozerov 65f6186713 write error message in the log file in case can not contact writer 2020-08-20 17:13:09 +02:00
babic_a 154f8af236 Add better log outputs 2020-08-20 17:07:41 +02:00
babic_a 38dcc92225 Make consumer and producer async 2020-08-20 16:59:54 +02:00
babic_a 9eb4561ded Add async implementation of Pika worker 2020-08-20 16:42:43 +02:00
Dmitry Ozerov cc67c371a6 correct printout 2020-08-20 16:06:23 +02:00
Dmitry Ozerov 7b2c727f95 log files from the writer clients in run_info directory 2020-08-20 15:49:06 +02:00
babic_a f5a10f5084 Change interface of reporting errors 2020-08-20 15:28:57 +02:00
babic_a 0995de2fe4 Remove requeue parameter 2020-08-20 15:27:43 +02:00
babic_a 82c9fc1d37 Add start download info in log 2020-08-20 15:24:41 +02:00
babic_a c0a98d17e6 Make the run file optional 2020-08-20 15:19:34 +02:00
babic_a f8053af252 Rename fix 2020-08-20 15:07:56 +02:00
babic_a 00f54fcf25 Remove bsread dependency 2020-08-20 15:03:55 +02:00
babic_a 5de5dec454 Add dataset determining logic to utils 2020-08-20 15:03:27 +02:00
babic_a 41202a60a6 Remove unused imports 2020-08-20 14:59:20 +02:00
babic_a e79e407651 Removed user_id from startup parameters 2020-08-20 14:49:06 +02:00
babic_a f2f5f362e6 Modify message broker client 2020-08-20 14:47:39 +02:00
babic_a f680ba2bbb Adjust starter to use broker client 2020-08-20 14:44:37 +02:00
babic_a 2bd6886969 Unify broker manager request creation 2020-08-20 14:37:59 +02:00
babic_a 449c16bb8a Move Epics Query address to config 2020-08-20 14:32:10 +02:00
babic_a 5766223bb4 Adapt broker to msg broker 2020-08-20 14:31:35 +02:00
babic_a a4c9e66a3f Add additional logger for run_info 2020-08-20 13:44:28 +02:00
babic_a c809992269 Remove useless variable 2020-08-20 13:40:25 +02:00
babic_a c8a6e0b8c3 Add run info file to request format 2020-08-20 13:31:11 +02:00
babic_a b5729f3427 Move request decoding to processing method 
Due to the audit log the processing function needs the
complete request.
 2020-08-20 13:29:21 +02:00
babic_a 37681c2473 Partial merge 2020-08-20 13:28:46 +02:00
babic_a a5112ac2b4 Fix audit writing 2020-08-20 13:15:54 +02:00
babic_a 641ed26e7a Remove Extended format from writer 2020-08-20 13:09:48 +02:00
babic_a 15c2ab58e2 Modify write requests scripts to be more concise 2020-08-20 13:08:13 +02:00
babic_a 9b8635e986 Fix write interface 2020-08-20 12:38:26 +02:00
babic_a 9d59b0b3a1 Added config and remove zmq config 2020-08-20 12:38:13 +02:00
babic_a 17bd9feaeb Changing request format 2020-08-20 12:37:50 +02:00
babic_a 5d09f6fb91 Remove old stream client 2020-08-20 12:37:29 +02:00
babic_a 16cbb159f2 Merge remote-tracking branch 'origin/master' 
# Conflicts:
#	sf_daq_broker/writer.py
 2020-08-20 12:36:47 +02:00