code: def create_schema(self, connection):
          
          if '.' not in self.table:
              return
  
          query = 'CREATE SCHEMA IF NOT EXISTS {schema_name};'.format(schema_name=self.table.split('.')[0])
          connection.cursor().execute(query)
docs: Will create the schema in the database