Skip to content

Commit 2bec0cb

Browse files
DXE-683 Rename Select Connector - CouchBase
1 parent 279c805 commit 2bec0cb

File tree

3 files changed

+19
-7
lines changed

3 files changed

+19
-7
lines changed

plugin_config.yml

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
id: 18f4ff11-b758-4bf2-9a37-719a22f5a4b8
2-
name: couchbase
3-
externalVersion: 1.0.0
4-
buildNumber: 1.0.0
2+
name: sc:couchbase
3+
buildNumber: 1.1.0
54
language: PYTHON27
65
hostTypes:
76
- UNIX

schema.json

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -438,5 +438,18 @@
438438
"type": "string"
439439
}
440440
}
441-
}
441+
},
442+
"snapshotParametersDefinition": {
443+
"type" : "object",
444+
"additionalProperties" : false,
445+
"required": ["resync"],
446+
"properties" : {
447+
"resync" : {
448+
"type": "boolean",
449+
"default": true,
450+
"prettyName": "Resynchronize dSource",
451+
"description": "Resynchronizing dSource will force a non-incremental load of data from the source. This operation is similar to creating a new dSource, but avoids duplicating storage requirements and maintains timeflow history."
452+
}
453+
}
454+
}
442455
}

src/plugin_runner.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ def source_config_discovery(source_connection, repository):
3939

4040

4141
@plugin.linked.post_snapshot()
42-
def linked_post_snapshot(staged_source, repository, source_config, snapshot_parameters):
42+
def linked_post_snapshot(staged_source, repository, source_config, optional_snapshot_parameters):
4343
return linked.post_snapshot(staged_source, repository, source_config,staged_source.parameters.d_source_type)
4444

4545

@@ -53,8 +53,8 @@ def linked_mount_specification(staged_source, repository):
5353

5454

5555
@plugin.linked.pre_snapshot()
56-
def linked_pre_snapshot(staged_source, repository, source_config, snapshot_parameters):
57-
if int(snapshot_parameters.resync) == 1:
56+
def linked_pre_snapshot(staged_source, repository, source_config, optional_snapshot_parameters):
57+
if int(optional_snapshot_parameters.resync) == 1:
5858
linked.resync(staged_source, repository, source_config, staged_source.parameters)
5959
linked.pre_snapshot(staged_source, repository, source_config, staged_source.parameters)
6060

0 commit comments

Comments
 (0)