code: def create_marker_table(self):
          
          connection = self.connect(autocommit=True)
          cursor = connection.cursor()
          try:
              cursor.execute(
                  """ CREATE TABLE {marker_table} (
                          id            BIGINT(20)    NOT NULL AUTO_INCREMENT,
                          update_id     VARCHAR(128)  NOT NULL,
                          target_table  VARCHAR(128),
                          inserted      TIMESTAMP DEFAULT NOW(),
                          PRIMARY KEY (update_id),
                          KEY id (id)
                      )
                  """
                  .format(marker_table=self.marker_table)
              )
          except mysql.connector.Error as e:
              if e.errno == errorcode.ER_TABLE_EXISTS_ERROR:
                  pass
              else:
                  raise
          connection.close()
docs: Create marker table if it doesn't exist.
  
          Using a separate connection since the transaction might have to be reset.