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