code: def validate_sqs_policy(self, accounts):
          
          sqs_queue_name = self.dbconfig.get('sqs_queue_name', self.ns)
          sqs_queue_region = self.dbconfig.get('sqs_queue_region', self.ns)
          sqs_account = AWSAccount.get(self.dbconfig.get('sqs_queue_account', self.ns))
          session = get_aws_session(sqs_account)
  
          sqs = session.client('sqs', region_name=sqs_queue_region)
          sqs_queue_url = sqs.get_queue_url(QueueName=sqs_queue_name, QueueOwnerAWSAccountId=sqs_account.account_number)
          sqs_attribs = sqs.get_queue_attributes(QueueUrl=sqs_queue_url['QueueUrl'], AttributeNames=['Policy'])
  
          policy = json.loads(sqs_attribs['Attributes']['Policy'])
  
          for account in accounts:
              arn = 'arn:aws:sns:*:{}:{}'.format(account.account_number, sqs_queue_name)
              if arn not in policy['Statement'][0]['Condition']['ForAnyValue:ArnEquals']['aws:SourceArn']:
                  self.log.warning('SQS policy is missing condition for ARN {}'.format(arn))
                  policy['Statement'][0]['Condition']['ForAnyValue:ArnEquals']['aws:SourceArn'].append(arn)
  
          sqs.set_queue_attributes(QueueUrl=sqs_queue_url['QueueUrl'], Attributes={'Policy': json.dumps(policy)})
docs: Given a list of accounts, ensures that the SQS policy allows all the accounts to write to the queue
  
          Args:
              accounts (`list` of :obj:`Account`): List of accounts
  
          Returns:
              `None`