def verify_file()

in infra-as-code/modules/ingest-pipeline/cf-ccai-conversation-upload/record.py [0:0]

• 9 lines of code
• 2 McCabe index (conditional complexity)

  def verify_file(self):
    bucket = self.storage_client.get_bucket(self.ingest_record_bucket_id)
    blob = bucket.blob(f'{str(datetime.now().year)}/ingest_filename_record.parquet')
    
    if blob.exists():
      print('Parquet exists')
      blob.download_to_filename('/tmp/ingest_filename_record.parquet')
      self.ingest_record_df = pd.read_parquet('/tmp/ingest_filename_record.parquet')
    else:
      raise Exception('Parquet file could not be found exists')