mirror of
https://github.com/resf/distro-tools.git
synced 2024-11-17 10:41:28 +00:00
30 lines
628 B
Python
30 lines
628 B
Python
"""
|
|
Temporal helper methods
|
|
"""
|
|
|
|
from temporalio.client import Client
|
|
|
|
from common.info import Info
|
|
|
|
|
|
class Temporal(object):
|
|
"""
|
|
Temporal helper singleton class
|
|
"""
|
|
|
|
client = None
|
|
|
|
def __init__(self, initialize=False):
|
|
if Temporal.client is None and not initialize:
|
|
raise Exception("Temporal client not initialized")
|
|
|
|
self.client = Temporal.client
|
|
|
|
async def connect(self):
|
|
info = Info()
|
|
Temporal.client = await Client.connect(
|
|
info.temporal_host(),
|
|
namespace=info.temporal_namespace(),
|
|
)
|
|
self.client = Temporal.client
|