| 
														
															@@ -40,7 +40,8 @@ def check_data(project, table, partition) -> int: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         t = odps.get_table(name=table) 
														 | 
														
														 | 
														
															         t = odps.get_table(name=table) 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         check_res = t.exist_partition(partition_spec=f'dt={partition}') 
														 | 
														
														 | 
														
															         check_res = t.exist_partition(partition_spec=f'dt={partition}') 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         if check_res: 
														 | 
														
														 | 
														
															         if check_res: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-            sql = f'select * from {project}.{table} where dt = {partition} limit 0,100' 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+            # sql = f'select * from {project}.{table} where dt = {partition} limit 0,100' 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+            sql = f'select * from loghubods.alg_recsys_sample_all where dt = 20240703 limit 0,100;' 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             with odps.execute_sql(sql=sql).open_reader() as reader: 
														 | 
														
														 | 
														
															             with odps.execute_sql(sql=sql).open_reader() as reader: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                 data_count = reader.count 
														 | 
														
														 | 
														
															                 data_count = reader.count 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         else: 
														 | 
														
														 | 
														
															         else: 
														 |