code: def create_marker_table(self):
          
          connection = self.connect()
          try:
              connection.execute_non_query(
                  """ CREATE TABLE {marker_table} (
                          id            BIGINT    NOT NULL IDENTITY(1,1),
                          update_id     VARCHAR(128)  NOT NULL,
                          target_table  VARCHAR(128),
                          inserted      DATETIME DEFAULT(GETDATE()),
                          PRIMARY KEY (update_id)
                      )
                  """
                  .format(marker_table=self.marker_table)
              )
          except _mssql.MSSQLDatabaseException as e:
              # Table already exists code
              if e.number == 2714:
                  pass
              else:
                  raise
          connection.close()
docs: Create marker table if it doesn't exist.
          Use a separate connection since the transaction might have to be reset.