code: def test_start_replication_expert_sql(self):
      conn = self.repl_connect(
          connection_factory=LogicalReplicationConnection
      )
      if conn is None:
          return
      cur = conn.cursor()
  
      self.create_replication_slot(cur, output_plugin="test_decoding")
      cur.start_replication_expert(
          sql.SQL(
              "START_REPLICATION SLOT {slot} LOGICAL 0/00000000"
          ).format(slot=sql.Identifier(self.slot))
      )
  
imports: import time
  from select import select
  import psycopg2
  from psycopg2 import sql
  from psycopg2.extras import PhysicalReplicationConnection, LogicalReplicationConnection, StopReplication
  from .None import testconfig
  import unittest
  from .testutils import ConnectingTestCase
  from .testutils import skip_before_postgres, skip_if_green
label_desc: Use image node_id 6 for calling the ReplicationTest obj's underlying member method code with example usage: obj.test_start_replication_expert_sql() without return types