from bigdata_research_tools.miners import NarrativeMiner
from bigdata_client.models.search import DocumentType
# For the example, you also need a bigdata client instance:
from bigdata_research_tools.client import bigdata_connection
bigdata = bigdata_connection()
deglobalization_narratives = [
"Global supply chains are fragmenting under geopolitical pressure",
"Companies are rethinking offshoring amid rising geopolitical risks",
"Trade flows are slowing as nations prioritize domestic resilience",
"Manufacturing reshoring may increase costs without productivity gains",
"Investors are underestimating the long-term impact of economic decoupling",
"Globalization tailwinds have turned into headwinds for corporate margins",
"Rising tariffs and sanctions are reshaping global investment patterns",
"Policy shifts toward economic nationalism are disrupting decades of integration",
"Multinationals face growing regulatory fragmentation across key markets",
"De-risking from China could strain supply chain efficiency and raise input costs",
"Emerging markets risk marginalization in a bifurcated global economy",
"Executives express concern over escalating costs of regionalization strategies",
"Cross-border capital flows are slowing amid increased scrutiny and controls",
"De-globalization is accelerating inflationary pressures across industries",
"Historical assumptions of global labor arbitrage are no longer holding"
]
tech_news_sources = bigdata.knowledge_graph.find_sources("MT Newswires")
tech_news_ids = [source.id for source in tech_news_sources if "MT Newswires" == source.name]
miner = NarrativeMiner(
narrative_sentences=deglobalization_narratives,
sources=tech_news_ids,
document_type=DocumentType.NEWS,
companies=["AAPL", "MSFT"],
start_date="2024-01-01",
end_date="2024-06-30",
fiscal_year=None,
rerank_threshold=0.7,
)