4343
4444if ( startDate === endDate ) {
4545 iterations . forEach ( ( params , i ) => {
46- publish ( params . metric . id + '_' + params . sql . type + '_' + params . lense . name , {
46+ publish ( params . metric . id + '_' + params . sql . type + '_' + params . lens . name , {
4747 type : 'incremental' ,
4848 protected : true ,
4949 bigquery : params . sql . type === 'histogram' ? { partitionBy : 'date' , clusterBy : [ 'client' ] } : { } ,
@@ -53,20 +53,20 @@ if (startDate === endDate) {
5353--DELETE FROM ${ ctx . self ( ) }
5454--WHERE date = '${ params . date } ';
5555 ` ) . query ( ctx => `
56- /* {"dataform_trigger": "report_complete", "date": "${ params . date } ", "name": "${ params . metric . id } ", "type": "${ params . sql . type } ", "lense": "${ params . lense . name } "} */` +
56+ /* {"dataform_trigger": "report_complete", "date": "${ params . date } ", "name": "${ params . metric . id } ", "type": "${ params . sql . type } ", "lense": "${ params . lens . name } "} */` +
5757params . sql . query ( ctx , params )
5858 )
5959 } )
6060} else {
6161 iterations . forEach ( ( params , i ) => {
6262 operate (
63- params . metric . id + '_' + params . sql . type + '_' + params . lense . name + '_' + params . date )
63+ params . metric . id + '_' + params . sql . type + '_' + params . lens . name + '_' + params . date )
6464 . tags ( [ 'crawl_complete' , 'reports' ] )
6565 . queries ( ctx => `
6666DELETE FROM reports.${ params . metric . id } _${ params . sql . type }
6767WHERE date = '${ params . date } ';
6868
69- /* {"dataform_trigger": "report_complete", "date": "${ params . date } ", "name": "${ params . metric . id } ", "type": "${ params . sql . type } ", "lense": "${ params . lense . name } "} */
69+ /* {"dataform_trigger": "report_complete", "date": "${ params . date } ", "name": "${ params . metric . id } ", "type": "${ params . sql . type } ", "lense": "${ params . lens . name } "} */
7070INSERT INTO reports.${ params . metric . id } _${ params . sql . type } ` +
7171params . sql . query ( ctx , params )
7272 )
0 commit comments