tap_linkedin_marketing/executor.py
def call_full_stream(self, stream):
        """
        Method to call all fully synced streams
        """
        pivots = (
            "CAMPAIGN",
            "CREATIVE",
            "CAMPAIGN_GROUP",
            "CONVERSION",
        )
        for pivot in pivots:
            request_config = {
                'url': self.url,
                'headers': self.build_headers(),
                'params': self.build_params(pivot),
                'run': True
            }

            LOGGER.info("Extracting {s} ".format(s=stream))

            self.call_stream(stream, request_config)

        Method to call all fully synced streams
        
Method to call all fully synced streams
Method to call all fully synced streams
def call_full_stream(self, stream):
        pivots = (
            "CAMPAIGN",
            "CREATIVE",
            "CAMPAIGN_GROUP",
            "CONVERSION",
        )
        for pivot in pivots:
            request_config = {
                'url': self.url,
                'headers': self.build_headers(),
                'params': self.build_params(pivot),
                'run': True
            }
            LOGGER.info("Extracting {s} ".format(s=stream))
            self.call_stream(stream, request_config)
def call_full_stream ( self , stream ) : pivots = ( "CAMPAIGN" , "CREATIVE" , "CAMPAIGN_GROUP" , "CONVERSION" , ) for pivot in pivots : request_config = { 'url' : self . url , 'headers' : self . build_headers ( ) , 'params' : self . build_params ( pivot ) , 'run' : True } LOGGER . info ( "Extracting {s} " . format ( s = stream ) ) self . call_stream ( stream , request_config )
Method to call all fully synced streams
Method to call all fully synced streams
"""
        Method to call all fully synced streams
        """
self
stream