Update from release_2024.01.10

.openapi-generator/FILES

@@ -237,7 +237,6 @@ docs/ValidateQueryResponse.md
 docs/View.md
 docs/ViewsApi.md
 docs/VirtualInstance.md
-docs/VirtualInstanceRrn.md
 docs/VirtualInstanceStats.md
 docs/VirtualInstancesApi.md
 docs/Workspace.md
@@ -488,7 +487,6 @@ rockset/model/user.py
 rockset/model/validate_query_response.py
 rockset/model/view.py
 rockset/model/virtual_instance.py
-rockset/model/virtual_instance_rrn.py
 rockset/model/virtual_instance_stats.py
 rockset/model/workspace.py
 rockset/model/xml_params.py
@@ -735,7 +733,6 @@ test/test_validate_query_response.py
 test/test_view.py
 test/test_views_api.py
 test/test_virtual_instance.py
-test/test_virtual_instance_rrn.py
 test/test_virtual_instance_stats.py
 test/test_virtual_instances_api.py
 test/test_workspace.py

HISTORY.md

@@ -1,3 +1,6 @@
+### v2.2.0 
+    - TODO
+
 ### v2.1.0
     - Get Collection Offset APIs
 

README.md

@@ -474,7 +474,6 @@ Class | Method | HTTP request | Description
  - [ValidateQueryResponse](docs/ValidateQueryResponse.md)
  - [View](docs/View.md)
  - [VirtualInstance](docs/VirtualInstance.md)
- - [VirtualInstanceRrn](docs/VirtualInstanceRrn.md)
  - [VirtualInstanceStats](docs/VirtualInstanceStats.md)
  - [Workspace](docs/Workspace.md)
  - [XmlParams](docs/XmlParams.md)

docs/CreateIntegrationRequest.md

@@ -11,6 +11,7 @@ Name | Type | Description | Notes
 **description** | **str** | Longer explanation for the integration. | [optional] 
 **dynamodb** | [**DynamodbIntegration**](DynamodbIntegration.md) |  | [optional] 
 **gcs** | [**GcsIntegration**](GcsIntegration.md) |  | [optional] 
+**is_write_enabled** | **bool** | is write access enabled for this integration. | [optional] 
 **kafka** | [**KafkaIntegration**](KafkaIntegration.md) |  | [optional] 
 **kinesis** | [**KinesisIntegration**](KinesisIntegration.md) |  | [optional] 
 **mongodb** | [**MongoDbIntegration**](MongoDbIntegration.md) |  | [optional] 

docs/Integration.md

@@ -16,6 +16,7 @@ Name | Type | Description | Notes
 **description** | **str** | Longer explanation for the integration. | [optional] 
 **dynamodb** | [**DynamodbIntegration**](DynamodbIntegration.md) |  | [optional] 
 **gcs** | [**GcsIntegration**](GcsIntegration.md) |  | [optional] 
+**is_write_enabled** | **bool** | is write access enabled for this integration | [optional] 
 **kafka** | [**KafkaIntegration**](KafkaIntegration.md) |  | [optional] 
 **kinesis** | [**KinesisIntegration**](KinesisIntegration.md) |  | [optional] 
 **mongodb** | [**MongoDbIntegration**](MongoDbIntegration.md) |  | [optional] 

docs/IntegrationsApi.md

@@ -1241,6 +1241,7 @@ SharedAccessSignature=<KeyValue>''',
             service_account_key_file_json="service_account_key_file_json_example",
         ),
     ),
+    is_write_enabled=True,
     kafka=KafkaIntegration(
         aws_role=AwsRole(
             aws_external_id="external id of aws",
@@ -1334,6 +1335,7 @@ Name | Type | Description  | Notes
  **description** | **str** | Longer explanation for the integration. | [optional]
  **dynamodb** | [**DynamodbIntegration**](DynamodbIntegration.md) |  | [optional]
  **gcs** | [**GcsIntegration**](GcsIntegration.md) |  | [optional]
+ **is_write_enabled** | **bool** | is write access enabled for this integration. | [optional]
  **kafka** | [**KafkaIntegration**](KafkaIntegration.md) |  | [optional]
  **kinesis** | [**KinesisIntegration**](KinesisIntegration.md) |  | [optional]
  **mongodb** | [**MongoDbIntegration**](MongoDbIntegration.md) |  | [optional]

docs/ScheduledLambda.md

@@ -16,7 +16,6 @@ Name | Type | Description | Notes
 **tag** | **str** | The query lambda tag. | [optional] 
 **total_times_to_execute** | **int** | The number of times to execute this scheduled query lambda. Once this scheduled query lambda has been executed this many times, it will no longer be executed. | [optional] 
 **version** | **str** | The version of the associated query lambda. | [optional] 
-**vi_rrn** | [**VirtualInstanceRrn**](VirtualInstanceRrn.md) |  | [optional] 
 **webhook_payload** | **str** | The payload that should be sent to the webhook. | [optional] 
 **webhook_url** | **str** | The URL of the webhook that should be triggered after this scheduled query lambda completes. | [optional] 
 **workspace** | **str** | Workspace of the associated query lambda. | [optional] 

docs/Source.md

@@ -25,6 +25,7 @@ Name | Type | Description | Notes
 **status** | **bool, date, datetime, dict, float, int, list, str, none_type** |  | [optional] [readonly] 
 **suspended_at** | **str** | ISO-8601 date when source was suspended, if suspended | [optional] [readonly] 
 **system** | [**SourceSystem**](SourceSystem.md) |  | [optional] 
+**write_api** | **{str: (bool, date, datetime, dict, float, int, list, str, none_type)}** |  | [optional] 
 **any string name** | **bool, date, datetime, dict, float, int, list, str, none_type** | any string name can be used but the value must be the correct type | [optional]
 
 [[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)

docs/Stats.md

@@ -7,6 +7,7 @@ Name | Type | Description | Notes
 **elapsed_time_ms** | **int** | Total execution time (including time queued) of the query, in milliseconds. | [optional] 
 **result_set_bytes_size** | **int** | Number of bytes in the query result set. Only populated if `status` is `COMPLETE`. Not populated for INSERT INTO queries. | [optional] 
 **result_set_document_count** | **int** | Number of documents returned by the query. Only populated if `status` is `COMPLETE`. | [optional] 
+**result_set_file_count** | **int** | Number of files written by by the query. Only populated if `status` is `COMPLETE` and the query is an export query. | [optional] 
 **throttled_time_ms** | **int** | Time query spent queued, in milliseconds. | [optional] 
 **any string name** | **bool, date, datetime, dict, float, int, list, str, none_type** | any string name can be used but the value must be the correct type | [optional]
 

docs/UpdateIntegrationRequest.md

@@ -10,6 +10,7 @@ Name | Type | Description | Notes
 **description** | **str** | Longer explanation for the integration. | [optional] 
 **dynamodb** | [**DynamodbIntegration**](DynamodbIntegration.md) |  | [optional] 
 **gcs** | [**GcsIntegration**](GcsIntegration.md) |  | [optional] 
+**is_write_enabled** | **bool** | is write access enabled for this integration. | [optional] 
 **kafka** | [**KafkaIntegration**](KafkaIntegration.md) |  | [optional] 
 **kinesis** | [**KinesisIntegration**](KinesisIntegration.md) |  | [optional] 
 **mongodb** | [**MongoDbIntegration**](MongoDbIntegration.md) |  | [optional] 

rockset/api/integrations_api.py

@@ -1881,6 +1881,7 @@ def update(
         description: str = None,
         dynamodb: DynamodbIntegration = None,
         gcs: GcsIntegration = None,
+        is_write_enabled: bool = None,
         kafka: KafkaIntegration = None,
         kinesis: KinesisIntegration = None,
         mongodb: MongoDbIntegration = None,
@@ -1925,6 +1926,7 @@ def update(
                     service_account_key_file_json="service_account_key_file_json_example",
                 ),
             ),
+            is_write_enabled=True,
             kafka=KafkaIntegration(
                 aws_role=AwsRole(
                     aws_external_id="external id of aws",
@@ -2010,6 +2012,7 @@ def update(
             description (str): Longer explanation for the integration.. [optional]
             dynamodb (DynamodbIntegration): [optional]
             gcs (GcsIntegration): [optional]
+            is_write_enabled (bool): is write access enabled for this integration.. [optional]
             kafka (KafkaIntegration): [optional]
             kinesis (KinesisIntegration): [optional]
             mongodb (MongoDbIntegration): [optional]

rockset/model/create_integration_request.py

@@ -112,6 +112,7 @@ def openapi_types():
             'description': (str, none_type),  # noqa: E501
             'dynamodb': (DynamodbIntegration, none_type),  # noqa: E501
             'gcs': (GcsIntegration, none_type),  # noqa: E501
+            'is_write_enabled': (bool, none_type),  # noqa: E501
             'kafka': (KafkaIntegration, none_type),  # noqa: E501
             'kinesis': (KinesisIntegration, none_type),  # noqa: E501
             'mongodb': (MongoDbIntegration, none_type),  # noqa: E501
@@ -132,6 +133,7 @@ def discriminator():
         'description': 'description',  # noqa: E501
         'dynamodb': 'dynamodb',  # noqa: E501
         'gcs': 'gcs',  # noqa: E501
+        'is_write_enabled': 'is_write_enabled',  # noqa: E501
         'kafka': 'kafka',  # noqa: E501
         'kinesis': 'kinesis',  # noqa: E501
         'mongodb': 'mongodb',  # noqa: E501
@@ -189,6 +191,7 @@ def _from_openapi_data(cls, name, *args, **kwargs):  # noqa: E501
             description (str): Longer explanation for the integration.. [optional]  # noqa: E501
             dynamodb (DynamodbIntegration): [optional]  # noqa: E501
             gcs (GcsIntegration): [optional]  # noqa: E501
+            is_write_enabled (bool): is write access enabled for this integration.. [optional]  # noqa: E501
             kafka (KafkaIntegration): [optional]  # noqa: E501
             kinesis (KinesisIntegration): [optional]  # noqa: E501
             mongodb (MongoDbIntegration): [optional]  # noqa: E501
@@ -253,6 +256,7 @@ def __init__(self, *, name, **kwargs):  # noqa: E501
             description (str): Longer explanation for the integration.. [optional]  # noqa: E501
             dynamodb (DynamodbIntegration): [optional]  # noqa: E501
             gcs (GcsIntegration): [optional]  # noqa: E501
+            is_write_enabled (bool): is write access enabled for this integration.. [optional]  # noqa: E501
             kafka (KafkaIntegration): [optional]  # noqa: E501
             kinesis (KinesisIntegration): [optional]  # noqa: E501
             mongodb (MongoDbIntegration): [optional]  # noqa: E501

rockset/model/integration.py

@@ -118,6 +118,7 @@ def openapi_types():
             'description': (str, none_type),  # noqa: E501
             'dynamodb': (DynamodbIntegration, none_type),  # noqa: E501
             'gcs': (GcsIntegration, none_type),  # noqa: E501
+            'is_write_enabled': (bool, none_type),  # noqa: E501
             'kafka': (KafkaIntegration, none_type),  # noqa: E501
             'kinesis': (KinesisIntegration, none_type),  # noqa: E501
             'mongodb': (MongoDbIntegration, none_type),  # noqa: E501
@@ -143,6 +144,7 @@ def discriminator():
         'description': 'description',  # noqa: E501
         'dynamodb': 'dynamodb',  # noqa: E501
         'gcs': 'gcs',  # noqa: E501
+        'is_write_enabled': 'is_write_enabled',  # noqa: E501
         'kafka': 'kafka',  # noqa: E501
         'kinesis': 'kinesis',  # noqa: E501
         'mongodb': 'mongodb',  # noqa: E501
@@ -205,6 +207,7 @@ def _from_openapi_data(cls, created_by, name, *args, **kwargs):  # noqa: E501
             description (str): Longer explanation for the integration.. [optional]  # noqa: E501
             dynamodb (DynamodbIntegration): [optional]  # noqa: E501
             gcs (GcsIntegration): [optional]  # noqa: E501
+            is_write_enabled (bool): is write access enabled for this integration. [optional]  # noqa: E501
             kafka (KafkaIntegration): [optional]  # noqa: E501
             kinesis (KinesisIntegration): [optional]  # noqa: E501
             mongodb (MongoDbIntegration): [optional]  # noqa: E501
@@ -275,6 +278,7 @@ def __init__(self, *, created_by, name, **kwargs):  # noqa: E501
             description (str): Longer explanation for the integration.. [optional]  # noqa: E501
             dynamodb (DynamodbIntegration): [optional]  # noqa: E501
             gcs (GcsIntegration): [optional]  # noqa: E501
+            is_write_enabled (bool): is write access enabled for this integration. [optional]  # noqa: E501
             kafka (KafkaIntegration): [optional]  # noqa: E501
             kinesis (KinesisIntegration): [optional]  # noqa: E501
             mongodb (MongoDbIntegration): [optional]  # noqa: E501

rockset/model/privilege.py

@@ -114,7 +114,7 @@ class Privilege(ModelNormal):
             'CREATE_NETWORK_CONFIGURATION_GLOBAL': "CREATE_NETWORK_CONFIGURATION_GLOBAL",
             'DELETE_NETWORK_CONFIGURATION_GLOBAL': "DELETE_NETWORK_CONFIGURATION_GLOBAL",
             'LIST_NETWORK_CONFIGURATIONS_GLOBAL': "LIST_NETWORK_CONFIGURATIONS_GLOBAL",
-            'UPDATE_ORG_QUERY_ROUTING': "UPDATE_ORG_QUERY_ROUTING",
+            'UPDATE_DEPLOYMENT_QUERY_ROUTING': "UPDATE_DEPLOYMENT_QUERY_ROUTING",
         },
     }
 

rockset/model/scheduled_lambda.py

@@ -31,9 +31,7 @@
 
 def lazy_import():
     from rockset.model.execution_status import ExecutionStatus
-    from rockset.model.virtual_instance_rrn import VirtualInstanceRrn
     globals()['ExecutionStatus'] = ExecutionStatus
-    globals()['VirtualInstanceRrn'] = VirtualInstanceRrn
 
 
 class ScheduledLambda(ModelNormal):
@@ -101,7 +99,6 @@ def openapi_types():
             'tag': (str, none_type),  # noqa: E501
             'total_times_to_execute': (int, none_type),  # noqa: E501
             'version': (str, none_type),  # noqa: E501
-            'vi_rrn': (VirtualInstanceRrn, none_type),  # noqa: E501
             'webhook_payload': (str, none_type),  # noqa: E501
             'webhook_url': (str, none_type),  # noqa: E501
             'workspace': (str, none_type),  # noqa: E501
@@ -125,7 +122,6 @@ def discriminator():
         'tag': 'tag',  # noqa: E501
         'total_times_to_execute': 'total_times_to_execute',  # noqa: E501
         'version': 'version',  # noqa: E501
-        'vi_rrn': 'vi_rrn',  # noqa: E501
         'webhook_payload': 'webhook_payload',  # noqa: E501
         'webhook_url': 'webhook_url',  # noqa: E501
         'workspace': 'workspace',  # noqa: E501
@@ -184,7 +180,6 @@ def _from_openapi_data(cls, *args, **kwargs):  # noqa: E501
             tag (str): The query lambda tag.. [optional]  # noqa: E501
             total_times_to_execute (int): The number of times to execute this scheduled query lambda. Once this scheduled query lambda has been executed this many times, it will no longer be executed.. [optional]  # noqa: E501
             version (str): The version of the associated query lambda.. [optional]  # noqa: E501
-            vi_rrn (VirtualInstanceRrn): [optional]  # noqa: E501
             webhook_payload (str): The payload that should be sent to the webhook.. [optional]  # noqa: E501
             webhook_url (str): The URL of the webhook that should be triggered after this scheduled query lambda completes.. [optional]  # noqa: E501
             workspace (str): Workspace of the associated query lambda.. [optional]  # noqa: E501
@@ -251,7 +246,6 @@ def __init__(self, **kwargs):  # noqa: E501
             tag (str): The query lambda tag.. [optional]  # noqa: E501
             total_times_to_execute (int): The number of times to execute this scheduled query lambda. Once this scheduled query lambda has been executed this many times, it will no longer be executed.. [optional]  # noqa: E501
             version (str): The version of the associated query lambda.. [optional]  # noqa: E501
-            vi_rrn (VirtualInstanceRrn): [optional]  # noqa: E501
             webhook_payload (str): The payload that should be sent to the webhook.. [optional]  # noqa: E501
             webhook_url (str): The URL of the webhook that should be triggered after this scheduled query lambda completes.. [optional]  # noqa: E501
             workspace (str): Workspace of the associated query lambda.. [optional]  # noqa: E501

rockset/model/source.py

@@ -137,6 +137,7 @@ def openapi_types():
             'status': (bool, date, datetime, dict, float, int, list, str, none_type, none_type),  # noqa: E501
             'suspended_at': (str, none_type),  # noqa: E501
             'system': (SourceSystem, none_type),  # noqa: E501
+            'write_api': ({str: (bool, date, datetime, dict, float, int, list, str, none_type)}, none_type),  # noqa: E501
         }
 
     @cached_property
@@ -165,6 +166,7 @@ def discriminator():
         'status': 'status',  # noqa: E501
         'suspended_at': 'suspended_at',  # noqa: E501
         'system': 'system',  # noqa: E501
+        'write_api': 'write_api',  # noqa: E501
     }
 
     read_only_vars = {
@@ -233,6 +235,7 @@ def _from_openapi_data(cls, *args, **kwargs):  # noqa: E501
             status (bool, date, datetime, dict, float, int, list, str, none_type): [optional]  # noqa: E501
             suspended_at (str): ISO-8601 date when source was suspended, if suspended. [optional]  # noqa: E501
             system (SourceSystem): [optional]  # noqa: E501
+            write_api ({str: (bool, date, datetime, dict, float, int, list, str, none_type)}): [optional]  # noqa: E501
         """
 
         _check_type = kwargs.pop('_check_type', True)
@@ -299,6 +302,7 @@ def __init__(self, **kwargs):  # noqa: E501
             snapshot (SourceSnapshot): [optional]  # noqa: E501
             snowflake (SourceSnowflake): [optional]  # noqa: E501
             system (SourceSystem): [optional]  # noqa: E501
+            write_api ({str: (bool, date, datetime, dict, float, int, list, str, none_type)}): [optional]  # noqa: E501
             _check_type (bool): if True, values for parameters in openapi_types
                                 will be type checked and a TypeError will be
                                 raised if the wrong type is input.

rockset/model/stats.py

@@ -84,6 +84,7 @@ def openapi_types():
             'elapsed_time_ms': (int, none_type),  # noqa: E501
             'result_set_bytes_size': (int, none_type),  # noqa: E501
             'result_set_document_count': (int, none_type),  # noqa: E501
+            'result_set_file_count': (int, none_type),  # noqa: E501
             'throttled_time_ms': (int, none_type),  # noqa: E501
         }
 
@@ -96,6 +97,7 @@ def discriminator():
         'elapsed_time_ms': 'elapsed_time_ms',  # noqa: E501
         'result_set_bytes_size': 'result_set_bytes_size',  # noqa: E501
         'result_set_document_count': 'result_set_document_count',  # noqa: E501
+        'result_set_file_count': 'result_set_file_count',  # noqa: E501
         'throttled_time_ms': 'throttled_time_ms',  # noqa: E501
     }
 
@@ -143,6 +145,7 @@ def _from_openapi_data(cls, *args, **kwargs):  # noqa: E501
             elapsed_time_ms (int): Total execution time (including time queued) of the query, in milliseconds.. [optional]  # noqa: E501
             result_set_bytes_size (int): Number of bytes in the query result set. Only populated if `status` is `COMPLETE`. Not populated for INSERT INTO queries.. [optional]  # noqa: E501
             result_set_document_count (int): Number of documents returned by the query. Only populated if `status` is `COMPLETE`.. [optional]  # noqa: E501
+            result_set_file_count (int): Number of files written by by the query. Only populated if `status` is `COMPLETE` and the query is an export query.. [optional]  # noqa: E501
             throttled_time_ms (int): Time query spent queued, in milliseconds.. [optional]  # noqa: E501
         """
 
@@ -198,6 +201,7 @@ def __init__(self, **kwargs):  # noqa: E501
             elapsed_time_ms (int): Total execution time (including time queued) of the query, in milliseconds.. [optional]  # noqa: E501
             result_set_bytes_size (int): Number of bytes in the query result set. Only populated if `status` is `COMPLETE`. Not populated for INSERT INTO queries.. [optional]  # noqa: E501
             result_set_document_count (int): Number of documents returned by the query. Only populated if `status` is `COMPLETE`.. [optional]  # noqa: E501
+            result_set_file_count (int): Number of files written by by the query. Only populated if `status` is `COMPLETE` and the query is an export query.. [optional]  # noqa: E501
             throttled_time_ms (int): Time query spent queued, in milliseconds.. [optional]  # noqa: E501
             _check_type (bool): if True, values for parameters in openapi_types
                                 will be type checked and a TypeError will be