def METHOD_NAME(self, *_, **__) -> Iterable[Either[AddLineageRequest]]:
    """
    Based on the query logs, prepare the lineage
    and send it to the sink
    """
    connection_type = str(self.service_connection.type.value)
    dialect = ConnectionTypeDialectMapper.dialect_of(connection_type)
    for table_query in self.get_table_query():
        lineages: Iterable[Either[AddLineageRequest]] = get_lineage_by_query(
            self.metadata,
            query=table_query.query,
            service_name=table_query.serviceName,
            database_name=table_query.databaseName,
            schema_name=table_query.databaseSchema,
            dialect=dialect,
            timeout_seconds=self.source_config.parsingTimeoutLimit,
        )
        for lineage_request in lineages or []:
            yield lineage_request