#!/usr/bin/env awe
from astro.main.AssociateList import AssociateList
from astro.main.SourceList import *
import time

slid1 = 135751 # 2df_R_13
slid2 = 136161 # 2df_V_13
slid3 = 136121 # 2df_I_13

sl1 = (SourceList.SLID == slid1)[0]
sl2 = (SourceList.SLID == slid2)[0]
sl3 = (SourceList.SLID == slid3)[0]

# commenting out either the first association
# or the sleep results in no error
al1 = AssociateList()
al1.input_lists = [sl1, sl2]
al1.make()
al1.commit()

time.sleep(35*60)

al2 = AssociateList()
al2.input_lists = [sl1, sl3]
al2.make()
al2.commit()



# output:
"""
virgo15:~/phd/awe>awe testAL8.py
[virgo15] 13:38:31 - Preparing for the matching
[virgo15] 13:40:01 - Found 2893 sources in SourceList with SLID = 135751
[virgo15] 13:44:54 - Found 2901 sources in SourceList with SLID = 136161
[virgo15] 13:44:54 - Looking for pairs
[virgo15] 13:45:34 - Looking for closest pairs
[virgo15] 13:45:35 - Filtered out 79 pairs
[virgo15] 13:45:35 - Found 2456 pairs
[virgo15] 13:45:35 - Inserting first half of pairs
[virgo15] 13:45:35 - Inserting second half of pairs
[virgo15] 13:45:36 - Inserting null associations from last input list
[virgo15] 13:45:36 - Inserting null associations from first input list
[virgo15] 13:45:36 - Created Chain AssociateList with ALID = 62441, name =  and 3528 associates!
[virgo15] 14:20:37 - Preparing for the matching
[virgo15] 14:21:44 - Found 2893 sources in SourceList with SLID = 135751
[virgo15] 14:22:46 - Found 6590 sources in SourceList with SLID = 136121
[virgo15] 14:22:46 - Looking for pairs
Traceback (most recent call last):
  File "testAL8.py", line 23, in ?
    al2.make()
  File "/Users/users/buddel/phd/awe/cvs/opipe/astro/main/AssociateList.py", line 146, in make
    self.associate_sourcelists()
  File "/Users/users/buddel/phd/awe/cvs/opipe/astro/main/AssociateList.py", line 207, in associate_sourcelists
    self.associate_lists(list1=self.input_lists[0], list2=self.input_lists[1])
  File "/Users/users/buddel/phd/awe/cvs/opipe/astro/main/AssociateList.py", line 1131, in associate_lists
    c.execute(Tquery)
cx_Oracle.DatabaseError: ORA-28576: lost RPC connection to external procedure agent
"""