Format
This commit is contained in:
@@ -11,7 +11,7 @@ namespace duckdb {
|
|||||||
typedef std::string (*simple_tf_t)(ClientContext &);
|
typedef std::string (*simple_tf_t)(ClientContext &);
|
||||||
|
|
||||||
struct RunOnceTableFunctionState : GlobalTableFunctionState {
|
struct RunOnceTableFunctionState : GlobalTableFunctionState {
|
||||||
RunOnceTableFunctionState() : run(false) {};
|
RunOnceTableFunctionState() : run(false){};
|
||||||
std::atomic<bool> run;
|
std::atomic<bool> run;
|
||||||
|
|
||||||
static unique_ptr<GlobalTableFunctionState> Init(ClientContext &,
|
static unique_ptr<GlobalTableFunctionState> Init(ClientContext &,
|
||||||
|
|||||||
@@ -62,11 +62,11 @@ void Watcher::Watch() {
|
|||||||
break; // DB went away, nothing to watch
|
break; // DB went away, nothing to watch
|
||||||
}
|
}
|
||||||
|
|
||||||
if (watched_database == nullptr) {
|
if (watched_database == nullptr) {
|
||||||
watched_database = db.get();
|
watched_database = db.get();
|
||||||
} else if (watched_database != db.get()) {
|
} else if (watched_database != db.get()) {
|
||||||
break; // DB changed, stop watching, will be restarted
|
break; // DB changed, stop watching, will be restarted
|
||||||
}
|
}
|
||||||
|
|
||||||
duckdb::Connection con{*db};
|
duckdb::Connection con{*db};
|
||||||
auto polling_interval = GetPollingInterval(*con.context);
|
auto polling_interval = GetPollingInterval(*con.context);
|
||||||
|
|||||||
@@ -1,3 +1,4 @@
|
|||||||
# name: test/sql/ui.test
|
# name: test/sql/ui.test
|
||||||
# description: test ui extension
|
# description: test ui extension
|
||||||
# group: [ui]
|
# group: [sql]
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user