diff --git a/app/methods/e_cvent_methods.py b/app/methods/e_cvent_methods.py index 97f654a..7383097 100644 --- a/app/methods/e_cvent_methods.py +++ b/app/methods/e_cvent_methods.py @@ -243,11 +243,11 @@ def get_contact_list(external_id: str=None, email: str=None): # Updated 2022-02-02 @logger_reset def get_recent_contact_list( - from_created_on = datetime.datetime.utcnow() + datetime.timedelta(minutes=-60), + from_created_on = None, to_created_on = None, # datetime.datetime.utcnow(), - from_updated_on = datetime.datetime.utcnow() + datetime.timedelta(minutes=-60), + from_updated_on = None, to_updated_on = None, - get_only = 'created', # created, updated/modified + # get_only = 'created', # created, updated/modified ): log.setLevel(logging.INFO) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL log.debug(locals()) @@ -259,14 +259,16 @@ def get_recent_contact_list( params = {} - from_created_on_str = from_created_on.isoformat() - log.info(f'From Created On: {from_created_on_str}') + if from_created_on: + from_created_on_str = from_created_on.isoformat() + log.info(f'From Created On: {from_created_on_str}') if to_created_on: to_created_on_str = to_created_on.isoformat() log.info(f'To Created On: {to_created_on_str}') - from_updated_on_str = from_updated_on.isoformat() - log.info(f'From Updated On: {from_updated_on_str}') + if from_updated_on: + from_updated_on_str = from_updated_on.isoformat() + log.info(f'From Updated On: {from_updated_on_str}') if to_updated_on: to_updated_on_str = to_updated_on.isoformat() log.info(f'To Updated On: {to_updated_on_str}') diff --git a/app/routers/e_cvent.py b/app/routers/e_cvent.py index 1863d33..8af0bda 100644 --- a/app/routers/e_cvent.py +++ b/app/routers/e_cvent.py @@ -27,7 +27,7 @@ router = APIRouter() async def process_recent_changes( from_created_on: datetime.datetime = datetime.datetime.utcnow() + datetime.timedelta(minutes=-60), # for Cvent "created" to_created_on: datetime.datetime = None, # for Cvent "created" - from_updated_on: datetime.datetime = datetime.datetime.utcnow() + datetime.timedelta(minutes=-60), # for Cvent "lastModified" + from_updated_on: datetime.datetime = None, # for Cvent "lastModified" to_updated_on: datetime.datetime = None, # for Cvent "lastModified" # type: str = 'created', # created, updated, created_updated get_only: str = None, # created, updated/modified @@ -47,7 +47,7 @@ async def process_recent_changes( to_created_on = to_created_on, from_updated_on = from_updated_on, to_updated_on = to_updated_on, - get_only = 'created', + # get_only = 'created', ): log.debug(cvent_contact_list_result) cvent_contact_list = cvent_contact_list_result