Show More
@@ -162,7 +162,11 b" def _init_celery(app_type=''):" | |||
|
162 | 162 | |
|
163 | 163 | log.debug('Got Pyramid ENV: %s', env) |
|
164 | 164 | |
|
165 |
|
|
|
165 | settings = env['registry'].settings | |
|
166 | celery_settings = get_celery_config(settings) | |
|
167 | ||
|
168 | # init and bootstrap StatsdClient | |
|
169 | StatsdClient.setup(settings) | |
|
166 | 170 | |
|
167 | 171 | setup_celery_app( |
|
168 | 172 | app=env['app'], root=env['root'], request=env['request'], |
@@ -188,10 +192,11 b' def on_beat_init(sender=None, conf=None,' | |||
|
188 | 192 | def task_prerun_signal(task_id, task, args, **kwargs): |
|
189 | 193 | ping_db() |
|
190 | 194 | statsd = StatsdClient.statsd |
|
195 | ||
|
191 | 196 | if statsd: |
|
192 | 197 | task_repr = getattr(task, 'name', task) |
|
193 | 198 | statsd.incr('rhodecode_celery_task_total', tags=[ |
|
194 |
'task:{}' |
|
|
199 | f'task:{task_repr}', | |
|
195 | 200 | 'mode:async' |
|
196 | 201 | ]) |
|
197 | 202 |
General Comments 0
You need to be logged in to leave comments.
Login now