Added sentry performance tracking
All checks were successful
continuous-integration/drone/push Build is passing
All checks were successful
continuous-integration/drone/push Build is passing
This commit is contained in:
parent
943e8b7a1f
commit
a64b14b06f
@ -6,6 +6,7 @@ import pika
|
|||||||
import json
|
import json
|
||||||
|
|
||||||
from sentry_sdk.integrations.logging import LoggingIntegration
|
from sentry_sdk.integrations.logging import LoggingIntegration
|
||||||
|
from sentry_sdk import start_transaction
|
||||||
import sentry_sdk
|
import sentry_sdk
|
||||||
|
|
||||||
from magic_doer import MagicDoer
|
from magic_doer import MagicDoer
|
||||||
@ -18,7 +19,8 @@ def message_callback(channel, method, properties, body):
|
|||||||
logging.warning(f"Invalid message recieved: {e}")
|
logging.warning(f"Invalid message recieved: {e}")
|
||||||
return
|
return
|
||||||
|
|
||||||
results = MagicDoer.run_everything(msg) # <- This is where the magic happens
|
with start_transaction(op="cnn-classification-service", name="classify-soundfile"):
|
||||||
|
results = MagicDoer.run_everything(msg) # <- This is where the magic happens
|
||||||
|
|
||||||
channel.basic_publish(
|
channel.basic_publish(
|
||||||
exchange=os.environ['PIKA_OUTPUT_EXCHANGE'],
|
exchange=os.environ['PIKA_OUTPUT_EXCHANGE'],
|
||||||
|
Loading…
Reference in New Issue
Block a user