def METHOD_NAME(self):
    publisher = JsonPublisher(
        self.mock_client,
        self.mock_storage_client,
        self.project_id,
        str(self.incremental_sql_path),
        self.api_version,
        self.test_bucket,
        ["submission_date:DATE:2020-03-15"],
    )
    mock_out = MagicMock(side_effect=[['{"a": 1}', '{"b": "cc"}'], None])
    mock_out.__iter__ = Mock(return_value=iter(['{"a": 1}', '{"b": "cc"}']))
    file_handler = MagicMock()
    file_handler.__enter__.return_value = mock_out
    smart_open.open = MagicMock(return_value=file_handler)
    publisher._gcp_convert_ndjson_to_json("test_path")
    smart_open.open.assert_has_calls(
        [
            call("gs://test-bucket/blob_path/000000000000.ndjson"),
            call("gs://test-bucket/blob_path/000000000000.json.tmp.gz", "w"),
        ]
    )
    file_handler.write.assert_has_calls(
        [call("["), call('{"a": 1}'), call(","), call('{"b": "cc"}'), call("]")]
    )