|
@@ -12,8 +12,8 @@ import (
|
|
|
|
|
|
func Test_task(t *testing.T) {
|
|
|
Mgo = MgoFactory(1, 3, 120, "192.168.3.207:27082", "extract_v3")
|
|
|
- //extract.StartExtractTaskId("5b8f804025e29a290415aee1")
|
|
|
- extract.StartExtractTestTask("5b8f804025e29a290415aee1", "5b8dcc45a5cb26b9b7f68469", "10", "result_v3", "track_v3")
|
|
|
+ extract.StartExtractTaskId("5b8f804025e29a290415aee1")
|
|
|
+ //extract.StartExtractTestTask("5b8f804025e29a290415aee1", "5b8dcc45a5cb26b9b7f68469", "10", "result_v3", "track_v3")
|
|
|
time.Sleep(300 * time.Second)
|
|
|
}
|
|
|
func Test_reg(t *testing.T) {
|
|
@@ -47,7 +47,7 @@ func Test_checkreg(t *testing.T) {
|
|
|
|
|
|
func Test_paths(t *testing.T) {
|
|
|
Mgo = MgoFactory(1, 3, 120, "192.168.3.207:27082", "extract_v3")
|
|
|
- tracks := track.GetTrackPath("5b8dd276a5cb26b9b7faaa7c", "projectname", "v3_track")
|
|
|
+ tracks := track.GetTrackPath("5b8dd276a5cb26b9b7faaa7c", "projectname", "rack_v3", "result_v3")
|
|
|
for code, v := range tracks {
|
|
|
if tmp, ok := v.([]map[string]interface{}); ok {
|
|
|
for k, v := range tmp {
|