async def METHOD_NAME(self, init) :
    config = validate(init)
    resource = await resource_db.load(config.source.id)
    self.config = config
    self.resource = resource
    self.client = MauticClient(**self.resource.credentials.get_credentials(self, None))
    self.client.set_retries(self.node.on_connection_error_repeat)