mirror of
https://github.com/ynput/ayon-core.git
synced 2025-12-24 21:04:40 +01:00
added trigger event method to base handler
This commit is contained in:
parent
b567af166d
commit
562c5a8e69
1 changed files with 21 additions and 0 deletions
|
|
@ -593,3 +593,24 @@ class BaseHandler(object):
|
||||||
self.log.debug(
|
self.log.debug(
|
||||||
"Action \"{}\" Triggered successfully".format(action_name)
|
"Action \"{}\" Triggered successfully".format(action_name)
|
||||||
)
|
)
|
||||||
|
|
||||||
|
def trigger_event(
|
||||||
|
self, topic, event_data={}, session=None, source=None,
|
||||||
|
event=None, on_error="ignore"
|
||||||
|
):
|
||||||
|
if session is None:
|
||||||
|
session = self.session
|
||||||
|
|
||||||
|
if not source and event:
|
||||||
|
source = event.get("source")
|
||||||
|
# Create and trigger event
|
||||||
|
event = fa_session.ftrack_api.event.base.Event(
|
||||||
|
topic=topic,
|
||||||
|
data=event_data,
|
||||||
|
source=source
|
||||||
|
)
|
||||||
|
session.event_hub.publish(event, on_error=on_error)
|
||||||
|
|
||||||
|
self.log.debug((
|
||||||
|
"Publishing event: {}"
|
||||||
|
).format(str(event.__dict__)))
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue