opal_common/sources/api_policy_source.py
async def check_for_changes(self):
        """
        Calling this method will trigger an api check to the remote.
        If after the request the watcher detects new bundle, it will call the
        callbacks registered with _on_new_policy().
        """
        logger.info(
            "Fetching changes from remote: '{remote}'", remote=self.remote_source_url)
        has_changes, prev, latest, prev_commit, new_commit = await self.api_update_policy()
        if not has_changes:
            logger.info(
                "No new version: current hash is: {head}", head=latest)
        else:
            logger.info(
                "Found new version: old version hash was '{prev_head}', new version hash is '{new_head}'",
                prev_head=prev, new_head=latest)
            await self._on_new_policy(old=prev_commit, new=new_commit)

        Calling this method will trigger an api check to the remote.
        If after the request the watcher detects new bundle, it will call the
        callbacks registered with _on_new_policy().
        
Calling this method will trigger an api check to the remote.
If after the request the watcher detects new bundle, it will call the
callbacks registered with _on_new_policy().
Calling this method will trigger an api check to the remote . If after the request the watcher detects new bundle it will call the callbacks registered with _on_new_policy () .
async def check_for_changes(self):
        logger.info(
            "Fetching changes from remote: '{remote}'", remote=self.remote_source_url)
        has_changes, prev, latest, prev_commit, new_commit = await self.api_update_policy()
        if not has_changes:
            logger.info(
                "No new version: current hash is: {head}", head=latest)
        else:
            logger.info(
                "Found new version: old version hash was '{prev_head}', new version hash is '{new_head}'",
                prev_head=prev, new_head=latest)
            await self._on_new_policy(old=prev_commit, new=new_commit)
async def check_for_changes ( self ) : logger . info ( "Fetching changes from remote: '{remote}'" , remote = self . remote_source_url ) has_changes , prev , latest , prev_commit , new_commit = await self . api_update_policy ( ) if not has_changes : logger . info ( "No new version: current hash is: {head}" , head = latest ) else : logger . info ( "Found new version: old version hash was '{prev_head}', new version hash is '{new_head}'" , prev_head = prev , new_head = latest ) await self . _on_new_policy ( old = prev_commit , new = new_commit )
Calling this method will trigger an api check to the remote.
Calling this method will trigger an api check to the remote .
"""
        Calling this method will trigger an api check to the remote.
        If after the request the watcher detects new bundle, it will call the
        callbacks registered with _on_new_policy().
        """
self