private async Task RunQuery()

in processing-pipelines/bigquery/query-runner/csharp/Startup.cs [74:87]

• 12 lines of code
• 1 McCabe index (conditional complexity)

        private async Task<BigQueryResults> RunQuery(BigQueryClient client, string country, ILogger<Startup> logger)
        {
            var sql = $@"SELECT date, cumulative_confirmed as num_reports
                FROM `bigquery-public-data.covid19_open_data.covid19_open_data`
                WHERE cumulative_confirmed > 0 and country_name = '{country}' and subregion1_code is NULL";

            var table = await GetOrCreateTable(client, logger);

            logger.LogInformation($"Executing query: \n{sql}");
            return await client.ExecuteQueryAsync(sql, null, new QueryOptions
            {
                DestinationTable = table.Reference
            });
        }