def METHOD_NAME(
    self,
    streams: List[ConfiguredAirbyteStream],
) -> Mapping[str, Any]:
    METHOD_NAME = {}
    for s in streams:
        # Only send a primary key for dedup sync
        if s.destination_sync_mode != DestinationSyncMode.append_dedup:
            s.primary_key = None
        stream = {
            "primaryKey": s.primary_key,
            "jsonSchema": s.stream.json_schema,
        }
        name = self.table_name_for_stream(
            s.stream.namespace,
            s.stream.name,
        )
        METHOD_NAME[name] = stream
    return METHOD_NAME