gistfile1.txt

def getChangeSetStatus(self):

  hourlyTimestamp = datetime.fromtimestamp(datetime.utcnow().timestamp() - (3600 * 6))
  dtFormat = '%Y-%m-%dT%H:%M:%S-00:00%z'
  query = f"SELECT EventType, LogDate, LogFileFieldNames, LogFile, Interval FROM EventLogFile WHERE EventType='ChangeSetOperation' AND Interval='Hourly' AND LogDate >= {hourlyTimestamp.strftime(dtFormat)}"
  url = f"{self._auth['instanceUrl']}/services/data/v{apiVersion}/query/?q={quote_plus(query)}"
  eventTypeLogResult = self._client.request('GET', url).json()

  for result in eventTypeLogResult['records']:
          
    url = f"{self._auth['instanceUrl']}{result['LogFile']}"
    logfileResult = self._client.request('GET', url).text
    df = pd.read_csv(StringIO(logfileResult), usecols=['CHANGE_SET_NAME'])

    for i, row in df.iterrows():
      sfdxCmd = f"sfdx force:source:retrieve -n '{row['CHANGE_SET_NAME']}' --targetusername={self.targetusername} --json"
      try:
        p = subprocess.Popen(sfdxCmd, shell=True,
                             stdout=subprocess.PIPE, encoding='utf-8')
        result = p.communicate()[0].strip()
        p.stdout.close()
      except:
        raise PopenError(f"Error with cmd: {sfdxCmd}. Error Msg: {sys.exc_info()[0]}")

      findCmd = f"find '{row['CHANGE_SET_NAME']}' -name '*' -type f -print | awk -F/ '{{ print $(NF-1) \" - \" $NF }}'"
      try:
        p = subprocess.Popen(findCmd, shell=True,
                             stdout=subprocess.PIPE, encoding='utf-8')
        result = p.communicate()[0].strip()
        p.stdout.close()
      except:
        raise PopenError(f"Error with cmd: {findCmd}. Error Msg: {sys.exc_info()[0]}")

      print(result)