def METHOD_NAME(self, schema):
    unlinked_sql = f"""
    SELECT
        count(*)
    FROM
        {schema}.financial_accounts_by_awards
    WHERE
        award_id IS NULL;
    """
    results = self.spark.sql(unlinked_sql)
    return results.collect()[0][0]